https://github.com/apache/airflow/blob/main/airflow/cli/commands/task_command.py#L145
"""Functions that need to be run before a Task is executed."""
        callbacks = task.on_execute_callback
        if callbacks:
            callbacks = callbacks if isinstance(callbacks, list) else [callbacks]
            for callback in callbacks:
                try:
                    callback(context)
                except Exception:
                    self.log.exception("Failed when executing execute callback")
    @provide_session
    def run(
        self,
        verbose: bool = True,
        ignore_all_deps: bool = False,
        ignore_depends_on_past: bool = False,
        wait_for_past_depends_before_skipping: bool = False,
        ignore_task_deps: bool = False,
        ignore_ti_state: bool = False,
        mark_success: bool = False,
        test_mode: bool = False,
        job_id: str | None = None,
        pool: str | None = None,