Skip to content

Commit 987cd71

Browse files
authored
fix:failure callback when task was removed from DB (#62)
1 parent 47f1d4c commit 987cd71

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

scheduler/models/scheduled_task.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,11 @@ def failure_callback(job, connection, result, *args, **kwargs):
3232
return
3333
model = apps.get_model(app_label='scheduler', model_name=model_name)
3434
task = model.objects.filter(job_id=job.id).first()
35-
mail_admins(f'Task {task.id}/{task.name} has failed',
36-
'See django-admin for logs', )
3735
if task is None:
36+
logger.warn(f'Could not find {model_name} task for job {job.id}')
3837
return
38+
mail_admins(f'Task {task.id}/{task.name} has failed',
39+
'See django-admin for logs', )
3940
task.job_id = None
4041
task.save(schedule_job=True)
4142

0 commit comments

Comments
 (0)