From c41f38d9ad608ee1252b9fe0e538d2e617c034e8 Mon Sep 17 00:00:00 2001
From: diazjj <jjdiaz@cttc.es>
Date: Mon, 29 Jul 2024 14:16:14 +0200
Subject: [PATCH] debugging
---
src/dlt/connector/client/DltEventsCollector.py | 10 +---------
1 file changed, 1 insertion(+), 9 deletions(-)
diff --git a/src/dlt/connector/client/DltEventsCollector.py b/src/dlt/connector/client/DltEventsCollector.py
index 39cf993f3..31eaf8542 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())
--
GitLab