fix: panic when image pull fails (#152)

airbytehq · Dec 12, 2024 · 164cad1 · 164cad1
1 parent 0a0dcba
commit 164cad1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/internal/cmd/local/k8s/load_images.go b/internal/cmd/local/k8s/load_images.go
@@ -38,9 +38,10 @@ func loadImages(ctx context.Context, dockerClient docker.Client, nodes []nodesli
 				pterm.Debug.Printfln("error pulling image %s", err)
 				// image pull errors are intentionally dropped because we're in a goroutine,
 				// and because we don't want to interrupt other image pulls.
+			} else {
+				defer r.Close()
+				io.Copy(io.Discard, r)
 			}
-			defer r.Close()
-			io.Copy(io.Discard, r)
 		}(img)
 	}
 	wg.Wait()