diff --git a/flow/connectors/core.go b/flow/connectors/core.go
index ffbf609521..9fafccdb6e 100644
--- a/flow/connectors/core.go
+++ b/flow/connectors/core.go
@@ -470,6 +470,7 @@ var (
 	_ CDCNormalizeConnector = &connclickhouse.ClickHouseConnector{}
 
 	_ GetTableSchemaConnector = &connpostgres.PostgresConnector{}
+	_ GetTableSchemaConnector = &connmysql.MySqlConnector{}
 	_ GetTableSchemaConnector = &connsnowflake.SnowflakeConnector{}
 	_ GetTableSchemaConnector = &connclickhouse.ClickHouseConnector{}
 
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
index 4526cf2b4f..5238410c4a 100644
--- a/flow/workflows/cdc_flow.go
+++ b/flow/workflows/cdc_flow.go
@@ -58,8 +58,7 @@ func GetSideEffect[T any](ctx workflow.Context, f func(workflow.Context) T) T {
 	})
 
 	var result T
-	err := sideEffect.Get(&result)
-	if err != nil {
+	if err := sideEffect.Get(&result); err != nil {
 		panic(err)
 	}
 	return result