From 90d3ffb2844c4cef195e70bed48d52765b4faf3d Mon Sep 17 00:00:00 2001 From: Marigold Date: Thu, 19 Dec 2024 12:00:57 +0100 Subject: [PATCH] wip --- etl/grapher_import.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/etl/grapher_import.py b/etl/grapher_import.py index 51d41f757ad..f28dc834193 100644 --- a/etl/grapher_import.py +++ b/etl/grapher_import.py @@ -27,7 +27,7 @@ from sqlalchemy import select, text, update from sqlalchemy.engine.base import Engine from sqlalchemy.exc import NoResultFound -from sqlalchemy.ext.asyncio import AsyncEngine, AsyncSession +from sqlalchemy.ext.asyncio import AsyncEngine, AsyncSession, async_sessionmaker from sqlalchemy.orm import Session from apps.backport.datasync import data_metadata as dm @@ -117,7 +117,7 @@ def upsert_dataset( assert source.name source_ids[hash(source)] = _upsert_source_to_db(session, source, ds.id) - await session.commit() + session.commit() return DatasetUpsertResult(ds.id, source_ids)