Skip to content

Commit e7a2dd5

Browse files
committed
docker workers: register thread_subscriptions worker as worker type
1 parent 7249a8c commit e7a2dd5

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

docker/configure_workers_and_start.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -322,6 +322,15 @@
322322
"shared_extra_conf": {},
323323
"worker_extra_conf": "",
324324
},
325+
"thread_subscriptions": {
326+
"app": "synapse.app.generic_worker",
327+
"listener_resources": ["client", "replication"],
328+
"endpoint_patterns": [
329+
"^/_matrix/client/unstable/io.element.msc4306.thread_subscriptions/.*",
330+
],
331+
"shared_extra_conf": {},
332+
"worker_extra_conf": "",
333+
},
325334
}
326335

327336
# Templates for sections that may be inserted multiple times in config files
@@ -431,6 +440,12 @@ def add_worker_roles_to_shared_config(
431440
if "federation_sender" in worker_types_set:
432441
shared_config.setdefault("federation_sender_instances", []).append(worker_name)
433442

443+
if "thread_subscriptions" in worker_types_set:
444+
# we can have multiple instances of thread_subscriptions workers
445+
shared_config.setdefault("stream_writers", {}).setdefault(
446+
"thread_subscriptions", []
447+
).append(worker_name)
448+
434449
if "event_persister" in worker_types_set:
435450
# Event persisters write to the events stream, so we need to update
436451
# the list of event stream writers

0 commit comments

Comments
 (0)