plugin: fix context

postfinance · May 4, 2020 · 37bdf5d · 37bdf5d
1 parent b5ff8a5
commit 37bdf5d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/internal/plugin/plugin.go b/internal/plugin/plugin.go
@@ -296,8 +296,11 @@ func (o *SyncOptions) Run() error {
 		return nil
 	}
 
+	ctx, cancel = context.WithTimeout(context.Background(), o.userSpecifiedTimeout)
+	defer cancel()
+
 	watch, err := batchClient.Watch(
-		context.TODO(),
+		ctx,
 		metav1.ListOptions{
 			LabelSelector: fmt.Sprintf("job=%s,jobSuffix=%s", job.Name, suffix),
 		},