address comments

listener.go

diff --git a/listener.go b/listener.go
index 3828aba..1fbd82e 100644
--- a/listener.go
+++ b/listener.go
@@ -123,15 +123,15 @@
 				err = insertDataScope(ds, tx)
 
 				// cache scopes for this cluster
-				if ds.ClusterID == apidInfo.ClusterID {
+				if (ds.ClusterID == apidInfo.ClusterID) && (err == nil) {
 					scopeCache.updateCache(&ds)
 				}
 			case common.Delete:
 				ds := makeDataScopeFromRow(change.OldRow)
-				deleteDataScope(ds, tx)
+				err = deleteDataScope(ds, tx)
 
 				// cache scopes for this cluster
-				if ds.ClusterID == apidInfo.ClusterID {
+				if (ds.ClusterID == apidInfo.ClusterID) && (err == nil) {
 					scopeCache.removeCache(&ds)
 				}
 			default: