Skip to content

Commit 13ff78c

Browse files
Revert "fix: add fair queueing for celery (#780)" (#781)
This reverts commit 857b3db.
1 parent 857b3db commit 13ff78c

File tree

2 files changed

+0
-6
lines changed

2 files changed

+0
-6
lines changed

apps/worker/main.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,6 @@ def worker(name: str, concurrency: int, debug: bool, queue: list[str]):
120120
concurrency,
121121
"-l",
122122
("debug" if debug else "info"),
123-
"-Ofair",
124123
]
125124
if get_config("setup", "celery_queues_enabled", default=True):
126125
actual_queues = _get_queues_param_from_queue_input(queue)

apps/worker/tests/unit/test_main.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,6 @@ def test_deal_worker_command_default(
143143
2,
144144
"-l",
145145
"info",
146-
"-Ofair",
147146
"-Q",
148147
f"celery,enterprise_celery,{BaseCeleryConfig.health_check_default_queue}",
149148
"-B",
@@ -189,7 +188,6 @@ def test_deal_worker_command(
189188
2,
190189
"-l",
191190
"info",
192-
"-Ofair",
193191
"-Q",
194192
f"simple,one,two,some,enterprise_simple,enterprise_one,enterprise_two,enterprise_some,{BaseCeleryConfig.health_check_default_queue}",
195193
"-B",
@@ -237,7 +235,6 @@ def test_deal_worker_no_beat(
237235
2,
238236
"-l",
239237
"info",
240-
"-Ofair",
241238
"-Q",
242239
f"simple,one,two,some,enterprise_simple,enterprise_one,enterprise_two,enterprise_some,{BaseCeleryConfig.health_check_default_queue}",
243240
]
@@ -283,7 +280,6 @@ def test_deal_worker_no_queues(
283280
2,
284281
"-l",
285282
"info",
286-
"-Ofair",
287283
"-B",
288284
"-s",
289285
"/home/codecov/celerybeat-schedule",
@@ -333,7 +329,6 @@ def test_deal_worker_no_queues_or_beat(
333329
2,
334330
"-l",
335331
"info",
336-
"-Ofair",
337332
]
338333
)
339334
mock_license_logging.assert_called_once()

0 commit comments

Comments
 (0)