100
priority *commonpb.Priority,
101
transactionPolicy historyi.TransactionPolicy,
103
>
resp, err := t.matchingRawClient.AddActivityTask(ctx, &matchingservice.AddActivityTaskRequest{
104
>
NamespaceId: task.NamespaceID,
105
>
Execution: &commonpb.WorkflowExecution{
106
>
WorkflowId: task.WorkflowID,
107
>
RunId: task.RunID,
108
>
},
109
>
TaskQueue: &taskqueuepb.TaskQueue{
110
>
Name: task.TaskQueue,
111
>
Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
112
>
},
113
>
ScheduledEventId: task.ScheduledEventID,
114
>
ScheduleToStartTimeout: durationpb.New(activityScheduleToStartTimeout),
115
>
Clock: vclock.NewVectorClock(t.shardContext.GetClusterMetadata().GetClusterID(), t.shardContext.GetShardID(), task.TaskID),
116
>
VersionDirective: directive,
117
>
Stamp: task.Stamp,
118
>
Priority: priority,
119
>
})
120
>
if _, isNotFound := err.(*serviceerror.NotFound); isNotFound {
121
// NotFound error is not expected for AddTasks calls
122
// but will be ignored by task error handling logic, so log it here