From 1dde5f7b08f804d30b12e089af5219adf2ae2094 Mon Sep 17 00:00:00 2001 From: Dylan De Faoite Date: Tue, 31 Mar 2026 20:59:09 +0100 Subject: [PATCH] fix(nlp): fix missing `processing` dataset status update --- server/queue/tasks.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/server/queue/tasks.py b/server/queue/tasks.py index d4dee0a..f338a3d 100644 --- a/server/queue/tasks.py +++ b/server/queue/tasks.py @@ -18,6 +18,10 @@ def process_dataset(self, dataset_id: int, posts: list, topics: dict): try: df = pd.DataFrame(posts) + dataset_manager.set_dataset_status( + dataset_id, "processing", "NLP Processing Started" + ) + processor = DatasetEnrichment(df, topics) enriched_df = processor.enrich() @@ -55,6 +59,10 @@ def fetch_and_process_dataset( df = pd.DataFrame(posts) + dataset_manager.set_dataset_status( + dataset_id, "processing", "NLP Processing Started" + ) + processor = DatasetEnrichment(df, topics) enriched_df = processor.enrich()