We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b9cde7a commit 780d34cCopy full SHA for 780d34c
1 file changed
examples/server_with_celery/example_app/celery.py
@@ -1,4 +1,8 @@
1
-from celery import Celery
2
-from flask_log_request_id.extras.celery import RequestIDAwareTask
+from celery import Celery, signals
+from flask_log_request_id.extras.celery import add_request_id_header, RequestIDAwareTask
3
4
+# Either sublcass all tasks from RequestIDAwareTask
5
celery = Celery(task_cls=RequestIDAwareTask)
6
+
7
+# Or alternatively register the provided signal handler
8
+signals.before_task_publish.connect(add_request_id_header)
0 commit comments