airflow/executors/celery_executor.py
def _num_tasks_per_fetch_process(self):
        """
        How many Celery tasks should be sent to each worker process.

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

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