235
// Inform the handler of the operation timeout via header.
236
// StartToClose takes precedence over ScheduleToClose since it is already capped by it.
238
>
if args.startToCloseTimeout > 0 {
239
opTimeout = args.startToCloseTimeout
240
}
242
opTimeout = min(args.scheduleToCloseTimeout-time.Since(args.scheduledTime), opTimeout)
243
}
245
>
if header == nil {
246
header = make(nexus.Header, 1) // It's most likely that we'll only be setting the new wire format header.
247
}
248
// Set the operation timeout header if not already set.
249
>
if opTimeoutHeader := header.Get(nexus.HeaderOperationTimeout); opTimeout != maxDuration && opTimeoutHeader == "" {
executors.go
250
header[nexus.HeaderOperationTimeout] = commonnexus.FormatDuration(opTimeout)
251
}
252
>
if e.Config.UseNewFailureWireFormat(ns.Name().String()) {
executors.go
253
// If this request is handled by a newer server that supports Nexus failure serialization, trigger that behavior.
254
header.Set(nexusrpc.HeaderTemporalNexusFailureSupport, "true")
255
}
256
257
>
callCtx, cancel := context.WithTimeout(ctx, callTimeout)
executors.go
258
>
defer cancel()
259
>
// Set this value on the parent context so that our custom HTTP caller can mutate it since we cannot access response headers directly.
260
>
callCtx = context.WithValue(callCtx, commonnexus.FailureSourceContextKey, &atomic.Value{})
261
>
262
>
options := nexus.StartOperationOptions{
263
>
Header: header,
264
>
CallbackURL: callbackURL,
265
>
RequestID: args.requestID,
266
>
CallbackHeader: nexus.Header{
267
>
commonnexus.CallbackTokenHeader: token,
268
>
},
269
>
Links: []nexus.Link{args.nexusLink},
270
>
}
271
>
272
>
var result *nexusrpc.ClientStartOperationResponse[*commonpb.Payload]
273
>
var callErr error
274
>
var startTime time.Time
275
>
if callTimeout < e.Config.MinRequestTimeout(ns.Name().String()) {
276
startTime = time.Now()
277
callErr = &operationTimeoutBelowMinError{timeoutType: timeoutType}
278
>
} else if args.endpointName == commonnexus.SystemEndpoint {
executors.go
279
startTime = time.Now()
280
result, callErr = e.startOnHistoryService(callCtx, ns, args, options)