Skip to content

Commit 142966d

Browse files
committed
raise in case of poll decision task error
1 parent 8b9823c commit 142966d

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

cadence/decision_loop.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -900,10 +900,11 @@ def poll(self) -> Optional[PollForDecisionTaskResponse]:
900900
logger.debug("PollForDecisionTask: %dms", (polling_end - polling_start).total_seconds() * 1000)
901901
except TChannelException as ex:
902902
logger.error("PollForDecisionTask error: %s", ex)
903-
return None
903+
raise
904904
if err:
905905
logger.error("PollForDecisionTask failed: %s", err)
906-
return None
906+
raise
907+
# return None
907908
if not task.task_token:
908909
logger.debug("PollForActivityTask has no task token (expected): %s", task)
909910
return None

0 commit comments

Comments
 (0)