Change Level of Retried GRPC Error Log to Debug (#168)

* Change Level of Retried GRPC Error Log to Debug

* Bump Version

---------

Co-authored-by: srhinos <[email protected]>

Author: macwilk

hatchet_sdk/clients/workflow_listener.py

@@ -1,6 +1,5 @@
 import asyncio
 import json
-import time
 from collections.abc import AsyncIterator
 from typing import AsyncGenerator
 
@@ -95,7 +94,7 @@ async def _init_producer(self):
                     try:
                         self.listener = await self._retry_subscribe()
 
-                        logger.debug(f"Workflow run listener connected.")
+                        logger.debug("Workflow run listener connected.")
 
                         # spawn an interrupter task
                         if self.interrupter is not None and not self.interrupter.done():
@@ -137,7 +136,7 @@ async def _init_producer(self):
                                 await self.events[subscription_id].put(workflow_event)
 
                     except grpc.RpcError as e:
-                        logger.error(f"grpc error in workflow run listener: {e}")
+                        logger.debug(f"grpc error in workflow run listener: {e}")
                         await asyncio.sleep(DEFAULT_WORKFLOW_LISTENER_RETRY_INTERVAL)
                         continue
 

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "hatchet-sdk"
-version = "0.36.13"
+version = "0.36.14"
 description = ""
 authors = ["Alexander Belanger <[email protected]>"]
 readme = "README.md"