airflow/utils/dag_processing.py
def wait_until_finished(self):
        """
        Sleeps until all the processors are done.
        """
        for file_path, processor in self._processors.items():
            while not processor.done:
                time.sleep(0.1)
def wait_until_finished(self):
        for file_path, processor in self._processors.items():
            while not processor.done:
                time.sleep(0.1)
def wait_until_finished ( self ) : for file_path , processor in self . _processors . items ( ) : while not processor . done : time . sleep ( 0.1 )
Sleeps until all the processors are done.
Sleeps until all the processors are done .