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):
        """
        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)
Called when a job has been found for the worker to run. Sends the job's
        RPC to the remote worker.