#OBS-I288: fix: removed data_format field from connector_instance (#260)

Sanketika-Obsrv · Oct 23, 2024 · 3c4901f · 3c4901f
1 parent 336f5de
commit 3c4901f
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/command-service/src/command/db_command.py b/command-service/src/command/db_command.py
@@ -265,7 +265,6 @@ def _insert_connector_instances(self, dataset_id, draft_dataset_record):
                     connector_config.connector_id,
                     connector_config.connector_config,
                     json.dumps(operations_config).replace("'", "''"),
-                    connector_config.data_format,
                     DatasetStatusType.Live.name,
                     json.dumps(emptyJson),
                     json.dumps(emptyJson),
@@ -277,15 +276,14 @@ def _insert_connector_instances(self, dataset_id, draft_dataset_record):
 
                     connector_config.connector_config,
                     json.dumps(connector_config.operations_config).replace("'", "''"),
-                    connector_config.data_format,
                     draft_dataset_record.get('updated_by'),
                     current_timestamp,
                     current_timestamp,
                     DatasetStatusType.Live.name,
                 )
                 insert_query = f"""
                     INSERT INTO connector_instances(id, dataset_id, connector_id, connector_config, operations_config,
-                    data_format, status, connector_state, connector_stats, created_by, updated_by, created_date, 
+                    status, connector_state, connector_stats, created_by, updated_by, created_date, 
                     updated_date, published_date)
                     VALUES (
                         %s,
@@ -300,13 +298,11 @@ def _insert_connector_instances(self, dataset_id, draft_dataset_record):
                         %s,
                         %s,
                         %s,
-                        %s,
                         %s
                     )
                     ON CONFLICT (id) DO UPDATE
                     SET connector_config = %s,
                     operations_config = %s,
-                    data_format = %s, 
                     updated_by = %s,
                     updated_date = %s,
                     published_date = %s,