chore(clickhouse): add target table identifier to error message

jacobmarble · jacobmarble · commit 69c6c5ed26b3 · 2026-04-14T15:05:43.000Z
diff --git a/materialize-clickhouse/driver.go b/materialize-clickhouse/driver.go
@@ -564,11 +564,12 @@ func (t *transactor) Acknowledge(ctx context.Context) (*pf.ConnectorState, error
 	for stateKey, si := range t.state {
 		// Skip targets tables which do not have a binding anymore
 		// since these tables might be deleted already
-		if _, found := t.bindingForStateKey(stateKey); !found {
+		b, found := t.bindingForStateKey(stateKey)
+		if !found {
 			continue
 		}
 		if err := t.moveStorePartitionsToTarget(ctx, si); err != nil {
-			return nil, fmt.Errorf("moving stage to target: %w", err)
+			return nil, fmt.Errorf("moving stage to target %s: %w", b.target.Identifier, err)
 		}
 	}
 	t.recovery = false

Original file line number	Diff line number	Diff line change
`@@ -564,11 +564,12 @@ func (t transactor) Acknowledge(ctx context.Context) (pf.ConnectorState, error`
`564`	`564`	`for stateKey, si := range t.state {`
`565`	`565`	`// Skip targets tables which do not have a binding anymore`
`566`	`566`	`// since these tables might be deleted already`
`567`		`- if _, found := t.bindingForStateKey(stateKey); !found {`
	`567`	`+ b, found := t.bindingForStateKey(stateKey)`
	`568`	`+ if !found {`
`568`	`569`	`continue`
`569`	`570`	`}`
`570`	`571`	`if err := t.moveStorePartitionsToTarget(ctx, si); err != nil {`
`571`		`- return nil, fmt.Errorf("moving stage to target: %w", err)`
	`572`	`+ return nil, fmt.Errorf("moving stage to target %s: %w", b.target.Identifier, err)`
`572`	`573`	`}`
`573`	`574`	`}`
`574`	`575`	`t.recovery = false`