def _handle_job(self):
        if self.job:
            self.log.debug("We have a job, we'll launch the task now.")
            self.functions[self.job.name].start_job(self.job)
We have a job, give it to the right plugin
dataset/ETHPy150Open openstack/turbo-hipster/turbo_hipster/worker_manager.py/ZuulClient._handle_job