highfive/jobs.py
def _distribute_jobs(self):
        """
        Distributes jobs from the active job set to any waiting get_job
        callbacks.
        """

        while (self._active_js.job_available()
                and len(self._ready_callbacks) > 0):
            job = self._active_js.get_job()
            self._job_sources[job] = self._active_js
            callback = self._ready_callbacks.popleft()
            callback(job)
def _distribute_jobs(self):
        while (self._active_js.job_available()
                and len(self._ready_callbacks) > 0):
            job = self._active_js.get_job()
            self._job_sources[job] = self._active_js
            callback = self._ready_callbacks.popleft()
            callback(job)
def _distribute_jobs ( self ) : while ( self . _active_js . job_available ( ) and len ( self . _ready_callbacks ) > 0 ) : job = self . _active_js . get_job ( ) self . _job_sources [ job ] = self . _active_js callback = self . _ready_callbacks . popleft ( ) callback ( job )
Distributes jobs from the active job set to any waiting get_job
        callbacks.
Distributes jobs from the active job set to any waiting get_job callbacks .