code: def setup_trigger_tasks(dag_maker):
      dagrun = setup_dagrun(dag_maker)
      executor = BaseExecutor()
      executor.execute_async = mock.Mock()
      enqueue_tasks(executor, dagrun)
      return executor, dagrun
  
imports: from __future__ import annotations
  import logging
  import sys
  from datetime import timedelta
  from unittest import mock
  import pendulum
  import pytest
  import time_machine
  from airflow.callbacks.callback_requests import CallbackRequest
  from airflow.cli.cli_config import DefaultHelpParser, GroupCommand
  from airflow.cli.cli_parser import AirflowHelpFormatter
  from airflow.executors.base_executor import BaseExecutor, RunningRetryAttemptType
  from airflow.models.baseoperator import BaseOperator
  from airflow.models.taskinstance import TaskInstance, TaskInstanceKey
  from airflow.utils import timezone
  from airflow.utils.state import State
label_desc: Use image node_id 17 for calling a global function with example usage: setup_trigger_tasks(dag_maker) and returns: executor,  dagrun