diff --git a/dlrover/python/elastic_agent/monitor/training.py b/dlrover/python/elastic_agent/monitor/training.py index 975aa2adb..49591ff36 100644 --- a/dlrover/python/elastic_agent/monitor/training.py +++ b/dlrover/python/elastic_agent/monitor/training.py @@ -123,19 +123,9 @@ def report_resource_with_step(self): except Exception as e: logger.warning(e) - def send_heartbeat(self): - try: - ts = int(time.time()) - action = self._master_client.report_heart_beat(ts) - if action: - pass - except Exception: - logger.warning("Fail to report a heartbeat.") - def _periodically_report(self): logger.info("Start training agent reporter.") while True: if self._group_rank == 0: self.report_resource_with_step() - self.send_heartbeat() time.sleep(15)