diff --git a/services/sentiment_analyzer/main.py b/services/sentiment_analyzer/main.py index c645223..4e9c4f9 100644 --- a/services/sentiment_analyzer/main.py +++ b/services/sentiment_analyzer/main.py @@ -125,6 +125,7 @@ async def process_article( content_hash=article.content_hash, ) session.add(db_article) + await session.flush() for ticker in tickers: sentiment = ArticleSentiment(