From b464da69ac18072c8c04257fc3a9032799098ac4 Mon Sep 17 00:00:00 2001 From: Mohammad Amin Date: Wed, 18 Jun 2025 13:37:25 +0330 Subject: [PATCH] fix: missing workflow_id! --- tasks/hivemind/query_data_sources.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tasks/hivemind/query_data_sources.py b/tasks/hivemind/query_data_sources.py index 41494f1..bf210f7 100644 --- a/tasks/hivemind/query_data_sources.py +++ b/tasks/hivemind/query_data_sources.py @@ -35,6 +35,7 @@ async def query(self, query: str) -> str | None: community_id=self.community_id, query=query, enable_answer_skipping=self.enable_answer_skipping, + workflow_id=self.workflow_id, ) # Add workflow_id to payload if available @@ -45,7 +46,7 @@ async def query(self, query: str) -> str | None: result = await client.execute_workflow( "HivemindWorkflow", payload, - id=f"hivemind-query-{self.community_id}-{uuid1()}", + id=f"hivemind-query-{self.community_id}-{self.workflow_id}", task_queue=hivemind_queue, )