code: async def __handle_backend_message(self, message):
          
          message_handlers = {
              BackendNewJob: self.__handle_new_job,
              BackendKillJob: self.kill_job,
              Ping: self.__handle_ping
          }
          try:
              func = message_handlers[message.__class__]
          except:
              raise TypeError("Unknown message type %s" % message.__class__)
          self._create_safe_task(func(message))
docs: Dispatch messages received from clients to the right handlers