(taskID string)
| 328 | } |
| 329 | |
| 330 | func (t autoEnqueueTrigger) idempotencyKey(taskID string) string { |
| 331 | normalized := t.normalized() |
| 332 | return fmt.Sprintf( |
| 333 | "task.auto_enqueue.%s.%s.%s", |
| 334 | strings.TrimSpace(taskID), |
| 335 | normalized.Kind, |
| 336 | normalized.Ref, |
| 337 | ) |
| 338 | } |
| 339 | |
| 340 | // autoEnqueueReadyDependents enqueues runs for dependents that became ready due to a |
| 341 | // completed blocker and opted in via AutoEnqueueOnReady. A failed/expired blocker does |