fix dead code warning

This commit is contained in:
Kenneth Kehl
2025-08-05 09:09:26 -07:00
parent 0e9760c291
commit 1f1c971257

View File

@@ -480,10 +480,11 @@ def make_task(app):
)
)
def on_failure(self, exc, task_id, args, kwargs, einfo=None):
def on_failure(self, exc, task_id, args, kwargs, einfo):
# enables request id tracing for these logs
with self.app_context():
app.logger.debug(f"einfo is {einfo}")
app.logger.exception(
"Celery task {task_name} (queue: {queue_name}) failed".format(
task_name=self.name,