Method
autoEnqueueReadyTaskDetached
(
ctx context.Context,
taskID string,
trigger autoEnqueueTrigger,
actor ActorContext,
)
Source from the content-addressed store, hash-verified
| 363 | } |
| 364 | |
| 365 | func (m *Service) autoEnqueueReadyTaskDetached( |
| 366 | ctx context.Context, |
| 367 | taskID string, |
| 368 | trigger autoEnqueueTrigger, |
| 369 | actor ActorContext, |
| 370 | ) { |
| 371 | autoCtx, cancel := context.WithTimeout(context.WithoutCancel(ctx), autoEnqueueDispatchTimeout) |
| 372 | defer cancel() |
| 373 | m.autoEnqueueReadyTasks(autoCtx, []string{taskID}, trigger, actor) |
| 374 | } |
| 375 | |
| 376 | func (m *Service) autoEnqueueReadyTasks( |
| 377 | ctx context.Context, |