https://github.com/apache/airflow/blob/main/airflow/cli/commands/task_command.py#L145
"""
    Execute Task (optionally with a Timeout) and push Xcom results.
    :param task_instance: the task instance
    :param context: Jinja2 context
    :param task_orig: origin task
    :meta private:
    """
    task_to_execute = task_instance.task
    if isinstance(task_to_execute, MappedOperator):
        raise AirflowException("MappedOperator cannot be executed.")
    
    
    
    execute_callable_kwargs = {}
    if task_instance.next_method:
        if task_instance.next_method:
            execute_callable = task_to_execute.resume_execution
            execute_callable_kwargs["next_method"] = task_instance.next_method
            execute_callable_kwargs["next_kwargs"] = task_instance.next_kwargs
    else:
        execute_callable = task_to_execute.execute
    
    
    if task_to_execute.execution_timeout: