fix: don't double add data to session

This commit is contained in:
Boris Arzentar 2025-07-08 23:11:30 +02:00
parent 66427e725c
commit b99b0455b0
No known key found for this signature in database
GPG key ID: D5CC274C784807B7

View file

@ -159,7 +159,6 @@ async def ingest_data(
session.add(dataset)
if len(new_datapoints) > 0:
session.add_all(new_datapoints)
dataset.data.extend(new_datapoints)
if len(existing_data_points) > 0:
@ -167,8 +166,6 @@ async def ingest_data(
await session.merge(data_point)
if len(dataset_new_data_points) > 0:
for data_point in dataset_new_data_points:
await session.merge(data_point)
dataset.data.extend(dataset_new_data_points)
await session.merge(dataset)