Use legacy queue for both train APIs.

This commit is contained in:
Rob Holland
2025-02-13 13:23:06 +00:00
parent 95d00d86d6
commit 87e22d3360

View File

@@ -49,7 +49,7 @@ class ToolWorkflow:
"""Execute a tool after confirmation and handle its result.""" """Execute a tool after confirmation and handle its result."""
workflow.logger.info(f"Confirmed. Proceeding with tool: {current_tool}") workflow.logger.info(f"Confirmed. Proceeding with tool: {current_tool}")
task_queue = TEMPORAL_LEGACY_TASK_QUEUE if current_tool == "BookTrain" else None task_queue = TEMPORAL_LEGACY_TASK_QUEUE if current_tool in ["SearchTrain", "BookTrain"] else None
try: try:
dynamic_result = await workflow.execute_activity( dynamic_result = await workflow.execute_activity(