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