code: def triggerer_run(
      skip_serve_logs: bool, capacity: int, triggerer_heartrate: float
  ):
      with _serve_logs(skip_serve_logs):
          triggerer_job_runner = TriggererJobRunner(
              job=Job(heartrate=triggerer_heartrate), capacity=capacity
          )
          run_job(
              job=triggerer_job_runner.job,
              execute_callable=triggerer_job_runner._execute,
          )
  
file_path: airflow/airflow/cli/commands/triggerer_command.py
imports: from __future__ import annotations
  from contextlib import contextmanager
  from functools import partial
  from multiprocessing import Process
  from typing import Generator
  from airflow import settings
  from airflow.cli.commands.daemon_utils import run_command_with_daemon_option
  from airflow.configuration import conf
  from airflow.jobs.job import Job, run_job
  from airflow.jobs.triggerer_job_runner import TriggererJobRunner
  from airflow.utils import cli
  from airflow.utils.providers_configuration_loader import providers_configuration_loaded
  from airflow.utils.serve_logs import serve_logs
label_desc: Use image node_id 2 for calling a global function with example usage: triggerer_run(skip_serve_logs, capacity, triggerer_heartrate) without return types