3049
3050
if pollerID, ok := ctx.Value(pollerIDKey).(string); ok && pollerID != "" {
3052
>
3053
>
// Also track by worker instance key for bulk cancellation during shutdown.
3054
>
// Use UUID (not pollerID) because pollerID is reused when forwarded.
3055
>
pollerTrackerKey := uuid.NewString()
3056
>
if workerInstanceKey != "" {
3057
e.workerInstancePollers.Add(workerInstanceKey, pollerTrackerKey, cancel)
3058
}
3059
3061
>
e.outstandingPollers.Delete(pollerID)
3062
>
if workerInstanceKey != "" {
3063
e.workerInstancePollers.Remove(workerInstanceKey, pollerTrackerKey)
3064
}