1252
timeoutType enumspb.TimeoutType,
1253
message string,
1255
>
failure := &failurepb.Failure{
1256
>
Message: message,
1257
>
FailureInfo: &failurepb.Failure_TimeoutFailureInfo{
1258
>
TimeoutFailureInfo: &failurepb.TimeoutFailureInfo{
1259
>
TimeoutType: timeoutType,
1260
>
LastHeartbeatDetails: a.lastHeartbeatDetails(ctx),
1261
>
},
1262
>
},
1263
>
}
1264
>
1265
>
a.Outcome.Get(ctx).Variant = &activitypb.ActivityOutcome_Failed_{
1266
>
Failed: &activitypb.ActivityOutcome_Failed{
1267
>
Failure: failure,
1268
>
},
1269
>
}
1270
>
1271
>
return nil
1272
>
}
1273
1274
// applyFailedAttempt mutates activity state when a worker yields with retries remaining.