highfive/jobs.py
def add_job_set(self, job_list):
        """
        Adds a job set to the manager's queue. If there is no job set running,
        it is activated immediately. A new job set handle is returned.
        """

        assert not self._closed

        results = Results(loop=self._loop)
        js = JobSet(job_list, results, self, loop=self._loop)
        if not js.is_done():
            if self._active_js is None:
                self._active_js = js
                logger.debug("activated job set")
                self._distribute_jobs()
            else:
                self._js_queue.append(js)
        else:
            logger.debug("new job set has no jobs")
        return JobSetHandle(js, results)
def add_job_set(self, job_list):
        assert not self._closed

        results = Results(loop=self._loop)
        js = JobSet(job_list, results, self, loop=self._loop)
        if not js.is_done():
            if self._active_js is None:
                self._active_js = js
                logger.debug("activated job set")
                self._distribute_jobs()
            else:
                self._js_queue.append(js)
        else:
            logger.debug("new job set has no jobs")
        return JobSetHandle(js, results)
def add_job_set ( self , job_list ) : assert not self . _closed results = Results ( loop = self . _loop ) js = JobSet ( job_list , results , self , loop = self . _loop ) if not js . is_done ( ) : if self . _active_js is None : self . _active_js = js logger . debug ( "activated job set" ) self . _distribute_jobs ( ) else : self . _js_queue . append ( js ) else : logger . debug ( "new job set has no jobs" ) return JobSetHandle ( js , results )
Adds a job set to the manager's queue. If there is no job set running,
        it is activated immediately. A new job set handle is returned.
Adds a job set to the manager s queue . If there is no job set running it is activated immediately . A new job set handle is returned .