highfive/master.py
def _job_loaded(self, job):
        """
        Called when a job has been found for the worker to run. Sends the job's
        RPC to the remote worker.
        """

        logger.debug("worker {} found a job".format(id(self)))

        if self._closed:
            self._manager.return_job(job)
            return

        self._job = job
        call_obj = self._job.get_call()
        call = (json.dumps(call_obj) + "\n").encode("utf-8")
        self._transport.write(call)
def _job_loaded(self, job):
        logger.debug("worker {} found a job".format(id(self)))

        if self._closed:
            self._manager.return_job(job)
            return

        self._job = job
        call_obj = self._job.get_call()
        call = (json.dumps(call_obj) + "\n").encode("utf-8")
        self._transport.write(call)
def _job_loaded ( self , job ) : logger . debug ( "worker {} found a job" . format ( id ( self ) ) ) if self . _closed : self . _manager . return_job ( job ) return self . _job = job call_obj = self . _job . get_call ( ) call = ( json . dumps ( call_obj ) + "\n" ) . encode ( "utf-8" ) self . _transport . write ( call )
Called when a job has been found for the worker to run. Sends the job's
        RPC to the remote worker.
Called when a job has been found for the worker to run . Sends the job s RPC to the remote worker .