code: def heartbeat(self):
          
          heartbeat = (HEARTBEAT_CODE).to_bytes(4, "little")
          r = self.task_incoming.send(heartbeat)
          logger.debug("Return from heartbeat : {}".format(r))
docs: Send heartbeat to the incoming task queue