103
}
104
105
>
callbackURL, err := buildCallbackURL(h.config.UseSystemCallbackURL(), h.config.CallbackURLTemplate(), ns, endpoint)
operation_tasks.go
106
>
if err != nil {
107
return fmt.Errorf("failed to build callback URL: %w", err)
108
}
109
111
>
if err != nil {
112
return err
113
}
114
116
>
callTimeout := h.config.RequestTimeout(ns.Name().String(), attrs.Destination)
117
>
var timeoutType enumspb.TimeoutType
118
>
// Adjust timeout based on remaining operation timeouts.
119
>
// ScheduleToStart takes precedence over ScheduleToClose since it is already capped by it.
120
>
if args.scheduleToStartTimeout > 0 {
121
callTimeout = min(callTimeout, args.scheduleToStartTimeout-elapsed)
122
timeoutType = enumspb.TIMEOUT_TYPE_SCHEDULE_TO_START
124
callTimeout = min(callTimeout, args.scheduleToCloseTimeout-elapsed)
125
timeoutType = enumspb.TIMEOUT_TYPE_SCHEDULE_TO_CLOSE