Agent: Clear event batches set and use correct variable name in send_all_events_to_island.py

This commit is contained in:
Shreya Malviya 2022-09-13 18:51:25 +05:30
parent 239b2e2550
commit 1d60cb160b
1 changed files with 3 additions and 3 deletions

View File

@ -67,7 +67,7 @@ class send_all_events_to_island:
timer = Timer() timer = Timer()
timer.set(self._time_period) timer.set(self._time_period)
self._event_batch = {} self._event_batch.clear()
while self._should_run_batch_and_send_thread: while self._should_run_batch_and_send_thread:
self._add_next_event_to_batch() self._add_next_event_to_batch()
@ -75,7 +75,7 @@ class send_all_events_to_island:
if timer.is_expired(): if timer.is_expired():
self._send_events_to_island() self._send_events_to_island()
timer.reset() timer.reset()
self._event_batch = {} self._event_batch.clear()
self._send_remaining_events() self._send_remaining_events()
@ -98,7 +98,7 @@ class send_all_events_to_island:
) )
except Exception as exc: except Exception as exc:
logger.warning( logger.warning(
f"Exception caught when connecting to the Island at {self.server_address}" f"Exception caught when connecting to the Island at {self._server_address}"
f": {exc}" f": {exc}"
) )