code: def execute_command(command_to_exec: CommandType) -> None:
      """Execute command."""
      dag_id, task_id = BaseExecutor.validate_airflow_tasks_run_command(
          command_to_exec
      )
      celery_task_id = app.current_task.request.id
      log.info(
          "[%s] Executing command in Celery: %s",
          celery_task_id,
          command_to_exec,
      )
      with _airflow_parsing_context_manager(
          dag_id=dag_id, task_id=task_id
      ):
          try:
              if settings.EXECUTE_TASKS_NEW_PYTHON_INTERPRETER:
                  _execute_in_subprocess(
                      command_to_exec, celery_task_id
                  )
              else:
                  _execute_in_fork(command_to_exec, celery_task_id)
          except Exception:
              Stats.incr("celery.execute_command.failure")
              raise
  
imports: from __future__ import annotations
  import contextlib
  import logging
  import math
  import os
  import subprocess
  import traceback
  import warnings
  from concurrent.futures import ProcessPoolExecutor
  from typing import TYPE_CHECKING, Any, Mapping, MutableMapping, Optional, Tuple
  from celery import Celery, Task, states
  from celery.backends.base import BaseKeyValueStoreBackend
  from celery.backends.database import DatabaseBackend, Task, retry, session_cleanup
  from celery.signals import import_modules
  from setproctitle import setproctitle
  from sqlalchemy import select
  import airflow.settings
  from airflow.configuration import conf
  from airflow.exceptions import AirflowException, RemovedInAirflow3Warning
  from airflow.executors.base_executor import BaseExecutor
  from airflow.stats import Stats
  from airflow.utils.dag_parsing_context import _airflow_parsing_context_manager
  from airflow.utils.log.logging_mixin import LoggingMixin
  from airflow.utils.net import get_hostname
  from airflow.utils.providers_configuration_loader import providers_configuration_loaded
  from airflow.utils.timeout import timeout
label_desc: Use image node_id 3 for calling a global function with example usage: execute_command(command_to_exec) without return types