Fix closed loop in tg interface (#424)

Fix bug with improperly closed loop when using TG interface.

Author: RLKRo

chatsky/messengers/telegram/interface.py

@@ -42,7 +42,10 @@ def __init__(
     async def connect(self, pipeline_runner: PipelineRunnerFunction, *args, **kwargs):
         await super().connect(pipeline_runner, *args, **kwargs)
         self.application.run_polling(
-            poll_interval=self.interval, timeout=self.timeout, allowed_updates=Update.ALL_TYPES
+            poll_interval=self.interval,
+            timeout=self.timeout,
+            allowed_updates=Update.ALL_TYPES,
+            close_loop=False,
         )
 
 
@@ -70,4 +73,9 @@ def __init__(
 
     async def connect(self, pipeline_runner: PipelineRunnerFunction, *args, **kwargs):
         await super().connect(pipeline_runner, *args, **kwargs)
-        self.application.run_webhook(listen=self.listen, port=self.port, allowed_updates=Update.ALL_TYPES)
+        self.application.run_webhook(
+            listen=self.listen,
+            port=self.port,
+            allowed_updates=Update.ALL_TYPES,
+            close_loop=False,
+        )

tests/messengers/telegram/utils.py

@@ -121,8 +121,8 @@ def _run_bot(self) -> None:
                     else:
                         raise RuntimeError(f"Update {update} type unknown!")
 
-    def run_polling(self, poll_interval: float, timeout: int, allowed_updates: List[str]) -> None:
+    def run_polling(self, *_, **__) -> None:
         return self._run_bot()
 
-    def run_webhook(self, listen: str, port: str, allowed_updates: List[str]) -> None:
+    def run_webhook(self, *_, **__) -> None:
         return self._run_bot()