First apply_async call to task of geventbased celery worker always fails #8677
Unanswered
karthikkj172
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I am running celery worker as a daemon in uwsgi:
attach-daemon2 = reloadsignal=1,stopsignal=3,control=1,cmd=/bin/celery -A <worker_module> worker -Q gen_queue --pool=gevent -Ofair --loglevel=info --concurrency=3 --heartbeat-interval 60 -n celery@%n
I have made sure to add monkey patching at both my celery app startup code and the task definition code.
When running a celery task on gevent pool:
task_id=custom_io_task.apply_async(args=("xyz"),task_id=task_id_gen())
I always get the following error at both the celery task log as well as the caller.
In my code , I have this call multiple times and I see trace only the first time.
could someone help me out here?
Beta Was this translation helpful? Give feedback.
All reactions