python_modules/dagster-graphql/dagster_graphql/implementation/pipeline_execution_manager.py
def join(self):
        '''Waits until all there are no processes enqueued.'''
        while True:
            with self._processes_lock:
                if not self._processes and self._processing_semaphore.locked():
                    return True
            gevent.sleep(0.1)
def join(self):
        '''Waits until all there are no processes enqueued.'''
        while True:
            with self._processes_lock:
                if not self._processes and self._processing_semaphore.locked():
                    return True
            gevent.sleep(0.1)
def join ( self ) : while True : with self . _processes_lock : if not self . _processes and self . _processing_semaphore . locked ( ) : return True gevent . sleep ( 0.1 )
Waits until all there are no processes enqueued.
Waits until all there are no processes enqueued .