79
80
if taskScheduledTime.Before(a.taskMinScheduledTime) {
82
>
tag.WorkflowNamespaceID(task.GetNamespaceID()),
83
>
tag.WorkflowID(task.GetWorkflowID()),
84
>
tag.WorkflowRunID(task.GetRunID()),
85
>
tag.TaskType(task.GetType()),
86
>
tag.TaskID(id),
87
>
tag.Timestamp(taskScheduledTime),
88
>
tag.CursorTimestamp(a.taskMinScheduledTime),
89
>
tag.ValueShardAllocateTimerBeforeRead,
90
>
)
91
>
// Theoritically we don't need to add the extra 1ms.
92
>
// Guess it's just to be extra safe here.
93
>
taskScheduledTime = a.taskMinScheduledTime.Add(common.ScheduledTaskMinPrecision)
94
>
}
95
}
96
task.SetVisibilityTime(taskScheduledTime)