Minimize calls to deploymentsChanged
diff --git a/data.go b/data.go
index ae8aafd..d36e745 100644
--- a/data.go
+++ b/data.go
@@ -144,8 +144,6 @@
return err
}
- deploymentsChanged <- depID
-
log.Debugf("deleteDeployment %s succeeded", depID)
return err
}
diff --git a/listener.go b/listener.go
index d895a31..43bab9a 100644
--- a/listener.go
+++ b/listener.go
@@ -188,9 +188,15 @@
err = tx.Commit()
if err != nil {
- log.Panicf("Error committing Snapshot change: %v", err)
+ log.Panicf("Error processing ChangeList: %v", err)
}
+ if len(deploymentsToDelete) > 0 {
+ deploymentsChanged <- deploymentsToDelete[0].ID // arbitrary, the ID doesn't matter
+ }
+
+ log.Debug("ChangeList processed")
+
for _, dep := range deploymentsToInsert {
queueDownloadRequest(dep)
}
