Skip to content

Commit 18c143a

Browse files
authored
[activity/logging] produce a log when activities time out (#1243)
* [cadence-client] produce a log when activities time out logging when activities time out will help with debugging * Update internal_task_handlers.go
1 parent 5571450 commit 18c143a

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

internal/internal_task_handlers.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1947,6 +1947,11 @@ func (ath *activityTaskHandlerImpl) Execute(taskList string, t *s.PollForActivit
19471947

19481948
dlCancelFunc()
19491949
if <-ctx.Done(); ctx.Err() == context.DeadlineExceeded {
1950+
ath.logger.Warn("Activity timeout.",
1951+
zap.String(tagWorkflowID, t.WorkflowExecution.GetWorkflowId()),
1952+
zap.String(tagRunID, t.WorkflowExecution.GetRunId()),
1953+
zap.String(tagActivityType, activityType),
1954+
)
19501955
return nil, ctx.Err()
19511956
}
19521957
if err != nil && err != ErrActivityResultPending {

0 commit comments

Comments
 (0)