345
return nil, err
346
}
347
>
attrs, ok := event.Attributes.(*historypb.HistoryEvent_ActivityTaskScheduledEventAttributes)
api.go
348
>
if !ok {
349
return nil, serviceerror.NewInvalidArgument("ActivityTaskScheduledEvent is invalid")
350
}
351
>
if attrs == nil || attrs.ActivityTaskScheduledEventAttributes == nil {
api.go
352
return nil, serviceerror.NewInvalidArgument("ActivityTaskScheduledEvent is incomplete")
353
}
354
355
>
originalOptions := attrs.ActivityTaskScheduledEventAttributes
api.go
356
>
357
>
activityOptions := &activitypb.ActivityOptions{
358
>
TaskQueue: &taskqueuepb.TaskQueue{
359
>
Name: originalOptions.TaskQueue.Name,
360
>
},
361
>
ScheduleToCloseTimeout: originalOptions.ScheduleToCloseTimeout,
362
>
ScheduleToStartTimeout: originalOptions.ScheduleToStartTimeout,
363
>
StartToCloseTimeout: originalOptions.StartToCloseTimeout,
364
>
HeartbeatTimeout: originalOptions.HeartbeatTimeout,
365
>
Priority: originalOptions.Priority,
366
>
RetryPolicy: originalOptions.RetryPolicy,
367
>
}
368
>
369
>
if updatedOptions, err = updateActivityOptions(ms, ai, activityOptions); err != nil {
370
return nil, err
371
}