diff --git a/policy/scan/local_scanner.go b/policy/scan/local_scanner.go
index 15bba211..f5de278a 100644
--- a/policy/scan/local_scanner.go
+++ b/policy/scan/local_scanner.go
@@ -301,6 +301,7 @@ func (s *LocalScanner) distributeJob(job *Job, ctx context.Context, upstream *up
 				return nil, false, err
 			}
 		}
+		runtime.UpstreamConfig = upstream
 
 		err = runtime.Connect(&plugin.ConnectReq{
 			Features: config.Features,