(self, pool)
return
Given a pool, submit jobs from the queue to the pool.
Given a pool, submit jobs from the queue to the pool.
Given a pool submit jobs from the queue to the pool .
def run_queue(self, pool):
        """Given a pool, submit jobs from the queue to the pool.
        """
        if self.job_queue is None:
            raise InternalException(
                'Got to run_queue with no job queue set'
            )

        def callback(result):
            """Note: mark_done, at a minimum, must happen here or dbt will
            deadlock during ephemeral result error handling!
            """
            self._handle_result(result)

            if self.job_queue is None:
                raise InternalException(
                    'Got to run_queue callback with no job queue set'
                )
            self.job_queue.mark_done(result.node.unique_id)

        while not self.job_queue.empty():
            node = self.job_queue.get()
            self._raise_set_error()
            runner = self.get_runner(node)
            # we finally know what we're running! Make sure we haven't decided
            # to skip it due to upstream failures
            if runner.node.unique_id in self._skipped_children:
                cause = self._skipped_children.pop(runner.node.unique_id)
                runner.do_skip(cause=cause)
            args = (runner,)
            self._submit(pool, args, callback)

        # block on completion
        if flags.FAIL_FAST:
            # checkout for an errors after task completion in case of
            # fast failure
            while self.job_queue.wait_until_something_was_done():
                self._raise_set_error()
        else:
            # wait until every task will be complete
            self.job_queue.join()

        # if an error got set during join(), raise it.
        self._raise_set_error()

        return
def run_queue ( self , pool ) : if self . job_queue is None : raise InternalException ( 'Got to run_queue with no job queue set' ) def callback ( result ) : """Note: mark_done, at a minimum, must happen here or dbt will
            deadlock during ephemeral result error handling!
            """ self . _handle_result ( result ) if self . job_queue is None : raise InternalException ( 'Got to run_queue callback with no job queue set' ) self . job_queue . mark_done ( result . node . unique_id ) while not self . job_queue . empty ( ) : node = self . job_queue . get ( ) self . _raise_set_error ( ) runner = self . get_runner ( node ) # we finally know what we're running! Make sure we haven't decided # to skip it due to upstream failures if runner . node . unique_id in self . _skipped_children : cause = self . _skipped_children . pop ( runner . node . unique_id ) runner . do_skip ( cause = cause ) args = ( runner , ) self . _submit ( pool , args , callback ) # block on completion if flags . FAIL_FAST : # checkout for an errors after task completion in case of # fast failure while self . job_queue . wait_until_something_was_done ( ) : self . _raise_set_error ( ) else : # wait until every task will be complete self . job_queue . join ( ) # if an error got set during join(), raise it. self . _raise_set_error ( ) return