def on_failure(self, exc, task_id, args, kwargs, einfo):
super().on_failure(exc, task_id, args, kwargs, einfo)<EOL>if isinstance(exc, OperationRunDoesNotExist):<EOL><INDENT>return<EOL><DEDENT>self._operation_run.on_failure()<EOL>
Update query status and send email notification to a user