We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 87f8895 commit ed22a08Copy full SHA for ed22a08
src/server/pipeline/match_data.py
@@ -51,7 +51,7 @@ def start(connection, added_or_updated_rows):
51
"Source {} with ID {} is matching multiple groups in pdp_contacts ({})"
52
.format(row["source_type"], row["source_id"], str(row_matches["matching_id"].drop_duplicates()))
53
)
54
- items_to_update["matching_id"][row_num] = row_group
+ items_to_update.loc[row_num, "matching_id"] = row_group
55
# Updating local pdp_contacts dataframe instead of a roundtrip to postgres within the loop.
56
# Indexing by iloc and vector of rows to keep the pd.DataFrame class and avoid implicit
57
# casting to a single-typed pd.Series.
0 commit comments