airflow/executors/celery_executor.py
def _num_tasks_per_send_process(self, to_send_count):
        """
        How many Celery tasks should each worker process send.

        :return: Number of tasks that should be sent per process
        :rtype: int
        """
        return max(1,
                   int(math.ceil(1.0 * to_send_count / self._sync_parallelism)))
def _num_tasks_per_send_process(self, to_send_count):
        return max(1,
                   int(math.ceil(1.0 * to_send_count / self._sync_parallelism)))
def _num_tasks_per_send_process ( self , to_send_count ) : return max ( 1 , int ( math . ceil ( 1.0 * to_send_count / self . _sync_parallelism ) ) )
How many Celery tasks should each worker process send.

        :return: Number of tasks that should be sent per process
        :rtype: int
How many Celery tasks should each worker process send .