docs: def start(self) -> None:
          """Start the celery task of this operation."""
          kwargs = self.celery_task_context
          # Update we the operation run id
          kwargs['operation_run_id'] = self.id  # pylint:disable=unsupported-assignment-operation
  
          async_result = celery_app.send_task(
              self.operation.celery_task,
              kwargs=kwargs,
              **self.operation.get_run_params())
          self.celery_task_id = async_result.id
          self.save()