diff --git a/src/dlt/connector/client/DltEventsCollector.py b/src/dlt/connector/client/DltEventsCollector.py index 39cf993f3e7fac22fa04d607ceb54f378121cc9d..31eaf8542c8763ee5200f36ef6c631298fe7be1f 100644 --- a/src/dlt/connector/client/DltEventsCollector.py +++ b/src/dlt/connector/client/DltEventsCollector.py @@ -36,7 +36,7 @@ class DltEventsCollector: self._terminate = asyncio.Event() self._dltgateway_stream = None - async def start(self) -> None: + async def run(self) -> None: event_handler = self._event_handler if event_handler is None: event_handler = lambda e: e @@ -90,11 +90,3 @@ class DltEventsCollector: if self._dltgateway_stream is not None: await self._dltgateway_stream.cancel() -# Usage example -async def main(): - gateway_client = DltGatewayClient() - collector = DltEventsCollector(gateway_client) - await collector.start() - -# Start the event loop -asyncio.run(main())