fix: missing workflow_id!

amindadgar · amindadgar · commit b464da69ac18 · 2025-06-18T13:37:25.000+03:30
diff --git 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,
         )
 

Original file line number	Diff line number	Diff line change
`@@ -35,6 +35,7 @@ async def query(self, query: str) -> str \| None:`
`35`	`35`	`community_id=self.community_id,`
`36`	`36`	`query=query,`
`37`	`37`	`enable_answer_skipping=self.enable_answer_skipping,`
	`38`	`+ workflow_id=self.workflow_id,`
`38`	`39`	`)`
`39`	`40`
`40`	`41`	`# Add workflow_id to payload if available`
`@@ -45,7 +46,7 @@ async def query(self, query: str) -> str \| None:`
`45`	`46`	`result = await client.execute_workflow(`
`46`	`47`	`"HivemindWorkflow",`
`47`	`48`	`payload,`
`48`		`- id=f"hivemind-query-{self.community_id}-{uuid1()}",`
	`49`	`+ id=f"hivemind-query-{self.community_id}-{self.workflow_id}",`
`49`	`50`	`task_queue=hivemind_queue,`
`50`	`51`	`)`
`51`	`52`