def METHOD_NAME(
    self, shutdown_event: threading.Event, heartbeat_period_s: float
):
    while not shutdown_event.wait(timeout=heartbeat_period_s):
        status_report = self.get_status_report()
        packed = messagepack.pack(status_report)
        self.results_passthrough.put({"message": packed})