-
-
Notifications
You must be signed in to change notification settings - Fork 3.6k
Upgrade celery to >= 4.2 #4643
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Comments
I just tried with
|
This happens when we execute the task with a callback The task is already running in a celery task, so when we call
That get is causing the error :) I'll try to see how we can fix/refactor this |
So, we can't execute the callback from outside a task anyway, it will block the request :/. So, I guess we just need to ignore the error as the docs shown. |
I tried a lot of ways, but looks like there is a bug in celery :/ # Celery's Group class does some special handling when an iterable with
# len() == 1 is passed in. This will be hit if there is only one server
# defined in the above queue lists
if len(tasks) > 1:
task_promise = group(*tasks).apply_async()
else:
task_promise = group(tasks).apply_async()
if callback:
task_promise.get(disable_sync_subtasks=False)
return callback.apply_async()
return task_promise |
We may need to do some changes before upgrading celery to 4.2, as we face some issues (#4640).
Some options are:
always_eager=False
) in devdisable_sync_subtask
option as mention in Celery update breaks our code #4640 (comment)The text was updated successfully, but these errors were encountered: