Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Commit 547326c

Browse files
committed
Remove obsolete "app" from worker templates
1 parent 1b238e8 commit 547326c

File tree

2 files changed

+2
-20
lines changed

2 files changed

+2
-20
lines changed

docker/conf-workers/synapse.supervisord.conf.j2

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ command=/usr/local/bin/python -m synapse.app.complement_fork_starter
66
--config-path="{{ main_config_path }}"
77
--config-path=/conf/workers/shared.yaml
88
{%- for worker in workers %}
9-
-- {{ worker.app }}
9+
-- synapse.app.generic_worker
1010
--config-path="{{ main_config_path }}"
1111
--config-path=/conf/workers/shared.yaml
1212
--config-path=/conf/workers/{{ worker.name }}.yaml
@@ -36,7 +36,7 @@ exitcodes=0
3636

3737
{% for worker in workers %}
3838
[program:synapse_{{ worker.name }}]
39-
command=/usr/local/bin/prefix-log /usr/local/bin/python -m {{ worker.app }}
39+
command=/usr/local/bin/prefix-log /usr/local/bin/python -m synapse.app.generic_worker
4040
--config-path="{{ main_config_path }}"
4141
--config-path=/conf/workers/shared.yaml
4242
--config-path=/conf/workers/{{ worker.name }}.yaml

docker/configure_workers_and_start.py

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -90,14 +90,12 @@
9090
# have to attach by instance_map to the master process and have client endpoints.
9191
WORKERS_CONFIG: Dict[str, Dict[str, Any]] = {
9292
"pusher": {
93-
"app": "synapse.app.generic_worker",
9493
"listener_resources": [],
9594
"endpoint_patterns": [],
9695
"shared_extra_conf": {},
9796
"worker_extra_conf": "",
9897
},
9998
"user_dir": {
100-
"app": "synapse.app.generic_worker",
10199
"listener_resources": ["client"],
102100
"endpoint_patterns": [
103101
"^/_matrix/client/(api/v1|r0|v3|unstable)/user_directory/search$"
@@ -108,7 +106,6 @@
108106
"worker_extra_conf": "",
109107
},
110108
"media_repository": {
111-
"app": "synapse.app.generic_worker",
112109
"listener_resources": ["media"],
113110
"endpoint_patterns": [
114111
"^/_matrix/media/",
@@ -126,7 +123,6 @@
126123
"worker_extra_conf": "enable_media_repo: true",
127124
},
128125
"appservice": {
129-
"app": "synapse.app.generic_worker",
130126
"listener_resources": [],
131127
"endpoint_patterns": [],
132128
"shared_extra_conf": {
@@ -135,14 +131,12 @@
135131
"worker_extra_conf": "",
136132
},
137133
"federation_sender": {
138-
"app": "synapse.app.generic_worker",
139134
"listener_resources": [],
140135
"endpoint_patterns": [],
141136
"shared_extra_conf": {},
142137
"worker_extra_conf": "",
143138
},
144139
"synchrotron": {
145-
"app": "synapse.app.generic_worker",
146140
"listener_resources": ["client"],
147141
"endpoint_patterns": [
148142
"^/_matrix/client/(v2_alpha|r0|v3)/sync$",
@@ -154,7 +148,6 @@
154148
"worker_extra_conf": "",
155149
},
156150
"client_reader": {
157-
"app": "synapse.app.generic_worker",
158151
"listener_resources": ["client"],
159152
"endpoint_patterns": [
160153
"^/_matrix/client/(api/v1|r0|v3|unstable)/publicRooms$",
@@ -189,7 +182,6 @@
189182
"worker_extra_conf": "",
190183
},
191184
"federation_reader": {
192-
"app": "synapse.app.generic_worker",
193185
"listener_resources": ["federation"],
194186
"endpoint_patterns": [
195187
"^/_matrix/federation/(v1|v2)/event/",
@@ -216,21 +208,18 @@
216208
"worker_extra_conf": "",
217209
},
218210
"federation_inbound": {
219-
"app": "synapse.app.generic_worker",
220211
"listener_resources": ["federation"],
221212
"endpoint_patterns": ["/_matrix/federation/(v1|v2)/send/"],
222213
"shared_extra_conf": {},
223214
"worker_extra_conf": "",
224215
},
225216
"event_persister": {
226-
"app": "synapse.app.generic_worker",
227217
"listener_resources": ["replication"],
228218
"endpoint_patterns": [],
229219
"shared_extra_conf": {},
230220
"worker_extra_conf": "",
231221
},
232222
"background_worker": {
233-
"app": "synapse.app.generic_worker",
234223
"listener_resources": [],
235224
"endpoint_patterns": [],
236225
# This worker cannot be sharded. Therefore, there should only ever be one
@@ -239,7 +228,6 @@
239228
"worker_extra_conf": "",
240229
},
241230
"event_creator": {
242-
"app": "synapse.app.generic_worker",
243231
"listener_resources": ["client"],
244232
"endpoint_patterns": [
245233
"^/_matrix/client/(api/v1|r0|v3|unstable)/rooms/.*/redact",
@@ -253,14 +241,12 @@
253241
"worker_extra_conf": "",
254242
},
255243
"frontend_proxy": {
256-
"app": "synapse.app.generic_worker",
257244
"listener_resources": ["client", "replication"],
258245
"endpoint_patterns": ["^/_matrix/client/(api/v1|r0|v3|unstable)/keys/upload"],
259246
"shared_extra_conf": {},
260247
"worker_extra_conf": "",
261248
},
262249
"account_data": {
263-
"app": "synapse.app.generic_worker",
264250
"listener_resources": ["client", "replication"],
265251
"endpoint_patterns": [
266252
"^/_matrix/client/(r0|v3|unstable)/.*/tags",
@@ -270,14 +256,12 @@
270256
"worker_extra_conf": "",
271257
},
272258
"presence": {
273-
"app": "synapse.app.generic_worker",
274259
"listener_resources": ["client", "replication"],
275260
"endpoint_patterns": ["^/_matrix/client/(api/v1|r0|v3|unstable)/presence/"],
276261
"shared_extra_conf": {},
277262
"worker_extra_conf": "",
278263
},
279264
"receipts": {
280-
"app": "synapse.app.generic_worker",
281265
"listener_resources": ["client", "replication"],
282266
"endpoint_patterns": [
283267
"^/_matrix/client/(r0|v3|unstable)/rooms/.*/receipt",
@@ -287,14 +271,12 @@
287271
"worker_extra_conf": "",
288272
},
289273
"to_device": {
290-
"app": "synapse.app.generic_worker",
291274
"listener_resources": ["client", "replication"],
292275
"endpoint_patterns": ["^/_matrix/client/(r0|v3|unstable)/sendToDevice/"],
293276
"shared_extra_conf": {},
294277
"worker_extra_conf": "",
295278
},
296279
"typing": {
297-
"app": "synapse.app.generic_worker",
298280
"listener_resources": ["client", "replication"],
299281
"endpoint_patterns": [
300282
"^/_matrix/client/(api/v1|r0|v3|unstable)/rooms/.*/typing"

0 commit comments

Comments
 (0)