bad rename

ilidemi · ilidemi · commit c3de9921e5e5 · 2026-04-20T15:08:45.000-07:00
diff --git a/flow/connectors/bigquery/source.go b/flow/connectors/bigquery/source.go
@@ -39,7 +39,7 @@ func (c *BigQueryConnector) ValidateMirrorSource(ctx context.Context, cfg *proto
 		}
 	}
 	if len(missingTables) > 0 {
-		return common.NewSourceTableMissingError(missingTables)
+		return common.NewSourceTablesMissingError(missingTables)
 	}
 
 	if cfg.SnapshotStagingPath == "" {
diff --git a/flow/connectors/mysql/validate.go b/flow/connectors/mysql/validate.go
@@ -26,7 +26,7 @@ func (c *MySqlConnector) CheckSourceTables(ctx context.Context, tableNames []*co
 		}
 	}
 	if len(missingTables) > 0 {
-		return common.NewSourceTableMissingError(missingTables)
+		return common.NewSourceTablesMissingError(missingTables)
 	}
 	return nil
 }
diff --git a/flow/connectors/postgres/validate.go b/flow/connectors/postgres/validate.go
@@ -73,7 +73,7 @@ func (c *PostgresConnector) CheckSourceTables(
 		}
 	}
 	if len(missingTables) > 0 {
-		return common.NewSourceTableMissingError(missingTables)
+		return common.NewSourceTablesMissingError(missingTables)
 	}
 
 	if pubName != "" && !noCDC {

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ func (c BigQueryConnector) ValidateMirrorSource(ctx context.Context, cfg proto`
`39`	`39`	`}`
`40`	`40`	`}`
`41`	`41`	`if len(missingTables) > 0 {`
`42`		`- return common.NewSourceTableMissingError(missingTables)`
	`42`	`+ return common.NewSourceTablesMissingError(missingTables)`
`43`	`43`	`}`
`44`	`44`
`45`	`45`	`if cfg.SnapshotStagingPath == "" {`
Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,7 @@ func (c MySqlConnector) CheckSourceTables(ctx context.Context, tableNames []co`
`26`	`26`	`}`
`27`	`27`	`}`
`28`	`28`	`if len(missingTables) > 0 {`
`29`		`- return common.NewSourceTableMissingError(missingTables)`
	`29`	`+ return common.NewSourceTablesMissingError(missingTables)`
`30`	`30`	`}`
`31`	`31`	`return nil`
`32`	`32`	`}`
Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,7 @@ func (c *PostgresConnector) CheckSourceTables(`
`73`	`73`	`}`
`74`	`74`	`}`
`75`	`75`	`if len(missingTables) > 0 {`
`76`		`- return common.NewSourceTableMissingError(missingTables)`
	`76`	`+ return common.NewSourceTablesMissingError(missingTables)`
`77`	`77`	`}`
`78`	`78`
`79`	`79`	`if pubName != "" && !noCDC {`