def end(self, synchronous=False):
        if synchronous:
            while any([
                    async.state not in celery_states.READY_STATES
                    for async in self.tasks.values()]):
                time.sleep(5)
dataset/ETHPy150Open airbnb/airflow/airflow/executors/celery_executor.py/CeleryExecutor.end/original