Enqueue release on clone change only (#2081)

Enqueue release on clone change only
fluxcd · May 23, 2019 · 81944c3 · 81944c3
2 parents 4e681a1 + 57fb1ad
commit 81944c3
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/integrations/helm/chartsync/chartsync.go b/integrations/helm/chartsync/chartsync.go
@@ -243,15 +243,15 @@ func (chs *ChartChangeSync) Run(stopCh <-chan struct{}, errc chan error, wg *syn
 							if cloneForChart.export != nil {
 								cloneForChart.export.Clean()
 							}
-						}
 
-						// Enqueue release
-						cacheKey, err := cache.MetaNamespaceKeyFunc(fhr.GetObjectMeta())
-						if err != nil {
-							continue
+							// we have a (new) clone, enqueue a release
+							cacheKey, err := cache.MetaNamespaceKeyFunc(fhr.GetObjectMeta())
+							if err != nil {
+								continue
+							}
+							chs.logger.Log("info", "enqueing release upgrade due to change in git chart source", "resource", fhr.ResourceID().String())
+							chs.releaseQueue.AddRateLimited(cacheKey)
 						}
-						chs.logger.Log("info", "enqueing release upgrade due to change in git chart source", "resource", fhr.ResourceID().String())
-						chs.releaseQueue.AddRateLimited(cacheKey)
 					}
 				}
 			case <-stopCh: