materialize-snowflake: unset internal state for empty bindings

estuary · Jan 26, 2024 · e6634b6 · e6634b6
1 parent 569e4a3
commit e6634b6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/materialize-snowflake/snowflake.go b/materialize-snowflake/snowflake.go
@@ -480,6 +480,7 @@ func (d *transactor) Store(it *m.StoreIterator) (m.StartCommitFunc, error) {
 	// we don't run queries belonging to bindings that have been removed
 	for _, b := range d.bindings {
 		if !b.store.stage.started {
+			delete(d.cp, b.target.StateKey)
 			continue
 		}