We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 66b25b1 commit df73b72Copy full SHA for df73b72
1 file changed
cadence/decision_loop.py
@@ -901,6 +901,10 @@ def poll(self) -> Optional[PollForDecisionTaskResponse]:
901
polling_end = datetime.datetime.now()
902
logger.debug("PollForDecisionTask: %dms", (polling_end - polling_start).total_seconds() * 1000)
903
except TChannelException as ex:
904
+ if f'{ex}' == "timeout":
905
+ logger.warning("PollForDecisionTask error: %s", ex)
906
+ logger.warning(f"LongPoll timeout -- no tasks available to execute -- exception message: {ex}")
907
+ return None
908
logger.error("PollForDecisionTask error: %s", ex)
909
logger.info(f"raising exception PollForDecisionTask {ex}")
910
raise
0 commit comments