code: async def handle_client_new_job(self, client_addr, message: ClientNewJob):
          
          self._logger.info("Adding a new job %s %s to the queue", client_addr, message.job_id)
          self._waiting_jobs[(client_addr, message.job_id)] = message
          await self.update_queue()
docs: Handle an ClientNewJob message. Add a job to the queue and triggers an update