fix: correct source hook to be pre-stop hook

argoproj-labs · Jul 16, 2021 · af46d66 · af46d66
1 parent 5544da5
commit af46d66
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/runner/sidecar/sources.go b/runner/sidecar/sources.go
@@ -87,7 +87,7 @@ func connectSources(ctx context.Context, toMain func(context.Context, []byte) er
 		}
 		if x, ok := sources[sourceName].(io.Closer); ok {
 			logger.Info("adding pre-stop hook", "source", sourceName)
-			addStopHook(func(ctx context.Context) error {
+			addPreStopHook(func(ctx context.Context) error {
 				logger.Info("closing", "source", sourceName)
 				return x.Close()
 			})