Skip to content

Commit 1b3789d

Browse files
pualienliquidpele
authored andcommitted
run selected tasks in right queue (#141)
* run selected tasks in right queue changed task.delay to task.apply_async to run tasks in selected queue when specified in database * format flake8 compatible * flake8 fix
1 parent 8f32f32 commit 1b3789d

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

django_celery_beat/admin.py

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -198,10 +198,14 @@ def run_tasks(self, request, queryset):
198198
self.celery_app.loader.import_default_modules()
199199
tasks = [(self.celery_app.tasks.get(task.task),
200200
loads(task.args),
201-
loads(task.kwargs))
201+
loads(task.kwargs),
202+
task.queue)
202203
for task in queryset]
203-
task_ids = [task.delay(*args, **kwargs)
204-
for task, args, kwargs in tasks]
204+
205+
task_ids = [task.apply_async(args=args, kwargs=kwargs, queue=queue)
206+
if queue and len(queue)
207+
else task.apply_async(args=args, kwargs=kwargs)
208+
for task, args, kwargs, queue in tasks]
205209
tasks_run = len(task_ids)
206210
self.message_user(
207211
request,

0 commit comments

Comments
 (0)