111
// Starting from the 8th attempt (after ~127s), workflow executions deletion must show some progress.
112
if activity.HasHeartbeatDetails(ctx) && activityInfo.Attempt > 7 {
114
>
if err := activity.GetHeartbeatDetails(ctx, &previousAttemptCount); err != nil {
115
logger.Error("Unable to get previous heartbeat details.", tag.Error(err))
116
return err
117
}
119
>
// No progress was made. Something bad happened on the task processor side or new executions were created during deletion.
120
>
// Return non-retryable error and workflow will try to delete executions again.
121
>
logger.Warn("No progress was made.", tag.Attempt(activityInfo.Attempt), tag.Counter(count))
122
>
return errors.NewNoProgress(count)
123
>
}
124
}
125