From 69b629c1152a8c689654e4c4a47e02c09c685e85 Mon Sep 17 00:00:00 2001 From: moelsayed Date: Sat, 24 Mar 2018 01:45:38 +0200 Subject: [PATCH] Update only for pre-pull and log cleanup --- cluster/cluster.go | 3 +++ cluster/logs.go | 3 +++ 2 files changed, 6 insertions(+) diff --git a/cluster/cluster.go b/cluster/cluster.go index f451a387..ef7e4096 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -299,6 +299,9 @@ func (c *Cluster) PrePullK8sImages(ctx context.Context) error { var errgrp errgroup.Group hosts := hosts.GetUniqueHostList(c.EtcdHosts, c.ControlPlaneHosts, c.WorkerHosts) for _, host := range hosts { + if !host.UpdateWorker { + continue + } runHost := host errgrp.Go(func() error { return docker.UseLocalOrPull(ctx, runHost.DClient, runHost.Address, c.SystemImages.Kubernetes, "pre-deploy", c.PrivateRegistriesMap) diff --git a/cluster/logs.go b/cluster/logs.go index ca574f33..b77b532a 100644 --- a/cluster/logs.go +++ b/cluster/logs.go @@ -19,6 +19,9 @@ func (c *Cluster) CleanDeadLogs(ctx context.Context) error { var errgrp errgroup.Group for _, host := range hosts { + if !host.UpdateWorker { + continue + } runHost := host errgrp.Go(func() error { return doRunLogCleaner(ctx, runHost, c.SystemImages.Alpine, c.PrivateRegistriesMap)