Use oip.Context() in dispatcher to enable trace threading (later). (#…

…555) I realized this wasn't properly threaded when opening: #554 spelling out how to save/restore trace headers. Signed-off-by: Matt Moore <[email protected]>
chainguard-dev · Sep 16, 2024 · c33ed00 · c33ed00
1 parent c79371c
commit c33ed00
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/workqueue/dispatcher/dispatcher.go b/pkg/workqueue/dispatcher/dispatcher.go
@@ -99,7 +99,7 @@ func HandleAsync(ctx context.Context, wq workqueue.Interface, concurrency int, f
 			}
 
 			// Attempt to perform the actual reconciler invocation.
-			if err := f(ctx, oip.Name()); err != nil {
+			if err := f(oip.Context(), oip.Name()); err != nil {
 				clog.WarnContextf(ctx, "Failed callback for key %q: %v", oip.Name(), err)
 
 				// Requeue if it fails (stops heartbeat).