code: def test_send_tasks_to_celery_hang(register_signals):
      """
      Test that celery_executor does not hang after many runs.
      """
      executor = celery_executor.CeleryExecutor()
  
      task = MockTask()
      task_tuples_to_send = [
          (None, None, None, task) for _ in range(26)
      ]
  
      for _ in range(250):
          # This loop can hang on Linux if celery_executor does something wrong with
          # multiprocessing.
          results = executor._send_tasks_to_celery(task_tuples_to_send)
          assert results == [
              (None, None, 1) for _ in task_tuples_to_send
          ]
  
imports: from __future__ import annotations
  import contextlib
  import logging
  import os
  import signal
  import sys
  from datetime import datetime, timedelta
  from unittest import mock
  import celery.contrib.testing.tasks
  import pytest
  import time_machine
  from celery import Celery
  from celery.result import AsyncResult
  from kombu.asynchronous import set_event_loop
  from airflow.configuration import conf
  from airflow.models.baseoperator import BaseOperator
  from airflow.models.dag import DAG
  from airflow.models.taskinstance import TaskInstance, TaskInstanceKey
  from airflow.providers.celery.executors import celery_executor, celery_executor_utils, default_celery
  from airflow.providers.celery.executors.celery_executor import CeleryExecutor
  from airflow.utils import timezone
  from airflow.utils.state import State
  from tests.test_utils import db
  from tests.test_utils.config import conf_vars
label_desc: Use image node_id 6 for calling a global function with example usage: test_send_tasks_to_celery_hang(register_signals) without return types