code: async def new_job(self, message: BackendNewJob):
          
          self._logger.info("Received request for jobid %s", message.job_id)
          future_results = asyncio.Future()
          out = await self._loop.run_in_executor(None, lambda: self.__new_job_sync(message, future_results))
          self._create_safe_task(self.handle_running_container(**out, future_results=future_results))
          await self._timeout_watcher.register_container(out["container_id"], out["orig_time_limit"], out["orig_hard_time_limit"])
docs: Handles a new job: starts the grading container