work_item = self.ei_job_result_queue.get(block=False, timeout=None)
payload = json.dumps(messages.ei_to_handler(*work_item)).encode("utf-8")
work_item = self.ei_job_result_queue.get(block=False, timeout=None)
payload = json.dumps(messages.ei_to_handler(*work_item)).encode("utf-8")