Skip to content

Commit 59c2dcf

Browse files
author
Jens Timmerman
authored
task -> shared_task (#21)
* task -> shared_task fixes #20 * keep current flow, but implement fallback to shared_task * revert change
1 parent 440b3f7 commit 59c2dcf

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

task_api/backends/celery.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import json
44

5-
from celery import task
5+
from celery import shared_task
66

77
from task_api.backends.base import TaskBackend
88
from task_api.models import TaskInfo
@@ -13,8 +13,7 @@ def run_task(self, info, class_str):
1313
result = execute.delay(info.pk, class_str)
1414
info.backend_data = json.dumps({'celery_id': result.id})
1515

16-
17-
@task
16+
@shared_task
1817
def execute(task_id, class_str):
1918
info = TaskInfo.objects.get(pk=task_id)
2019
cls = CeleryBackend().resolve_class(class_str)

0 commit comments

Comments
 (0)