fixes

Author: idanasulin2706

superclient/agent/interceptor.py

@@ -7,6 +7,7 @@
 from ..util.config import get_topics_list, is_disabled
 from .metadata import fetch_metadata, optimal_cfg
 from ..core.reporter import send_clients_msg
+from ..core.manager import normalize_bootstrap
 from .tracker import ProducerTracker, Heartbeat
 
 logger = get_logger("agent.interceptor")
@@ -77,6 +78,7 @@ def close_patch(inner, *a, **kw):
 
             self.close = close_patch
             self._superstream_patch = True
+        orig_init(self, *args, **kwargs)
         send_clients_msg(tr, error_msg)
         logger.info("Successfully optimized producer configuration for {}", client_id)
 
@@ -145,6 +147,7 @@ async def stop_patch(inner, *a, **kw):
 
             self.stop = stop_patch
             self._superstream_patch = True
+        orig_init(self, *args, **kwargs)
         send_clients_msg(tr, error_msg)
         logger.info("Successfully optimized producer configuration for {}", client_id)
 

superclient/agent/tracker.py

@@ -71,6 +71,7 @@ def ensure(cls):
     def register_tracker(cls, tracker: ProducerTracker):
         """Register a new producer tracker."""
         with cls._track_lock:
+            tracker.last_hb = time.time()  # Set initial timestamp to prevent immediate reporting
             cls._trackers[tracker.uuid] = tracker
 
     @classmethod