ff do not push

Author: alexstoick

flow/internal/flow_configuration_helpers.go

@@ -61,7 +61,7 @@ func FetchTableMappingsFromDB(ctx context.Context, flowJobName string, version u
 		return nil, err
 	}
 	rows, err := pool.Query(ctx,
-		"select table_mapping from table_mappings where flow_name = $1 AND version = $2",
+		"select table_mappings from table_mappings where flow_name = $1 AND version = $2",
 		flowJobName, version,
 	)
 	if err != nil {

nexus/catalog/migrations/V49__table_mappings_table.sql

@@ -1,6 +1,6 @@
 CREATE TABLE IF NOT EXISTS table_mappings (
-    flow_name varchar(255) not null,Expand commentComment on line R2ResolvedCode has comments. Press enter to view.
-    version int32 not null default 1,
-    table_mappings []bytea not null,
+    flow_name varchar(255) not null,
+    version int not null default 1,
+    table_mappings bytea[] not null,
     primary key (flow_name, version)
 );