Skip to content

Commit

Permalink
Log beat signals for xray integration testing (#2263)
Browse files Browse the repository at this point in the history
Co-authored-by: Mike Pond <[email protected]>
  • Loading branch information
jimleroyer and P0NDER0SA authored Aug 22, 2024
1 parent 4eb8d7e commit c54102b
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion app/celery/celery.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,8 @@ def init_app(self, app):
signals.task_failure.connect(xray_task_failure)
signals.task_postrun.connect(xray_task_postrun)
signals.task_prerun.connect(xray_task_prerun)
signals.beat_init.connect(xray_task_prerun)
signals.beat_init.connect(lambda: app.logger.info("Celery beat signal intercepted"))
signals.beat_embedded_init.connect(lambda: app.logger.info("Celery embedded beat signal intercepted"))

# See https://docs.celeryproject.org/en/stable/userguide/configuration.html
self.conf.update(
Expand Down

0 comments on commit c54102b

Please sign in to comment.