Skip to content
This repository was archived by the owner on Jul 29, 2024. It is now read-only.

Commit 43ca091

Browse files
Update connector.py
1 parent dcd026e commit 43ca091

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

labelpandas/connector.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,15 +67,15 @@ def create_data_rows(lb_client:Client, base_client:baseClient, row:pandas.core.s
6767
metadata_fields = [{"schema_id" : metadata_name_key_to_schema['lb_integration_source'], "value" : "Pandas"}]
6868
if metadata_index:
6969
for metadata_field_name in metadata_index.keys():
70-
metadata_value = base_client.process_metadata_value(
70+
input_metadata = base_client.process_metadata_value(
7171
metadata_value=row[metadata_field_name],
7272
metadata_type=metadata_index[metadata_field_name],
7373
parent_name=metadata_field_name,
7474
metadata_name_key_to_schema=metadata_name_key_to_schema,
7575
divider=divider
7676
)
77-
if metadata_value:
78-
metadata_fields.append({"schema_id" : metadata_name_key_to_schema[metadata_field_name], "value" : metadata_value})
77+
if input_metadata:
78+
metadata_fields.append({"schema_id" : metadata_name_key_to_schema[metadata_field_name], "value" : input_metadata})
7979
else:
8080
continue
8181
return {"row_data":row_data,"global_key":str(row[global_key_col]),"external_id":str(row[external_id_col]),"metadata_fields":metadata_fields}

0 commit comments

Comments
 (0)