From 6ce236ba8ba2235eea559b96f3e0b05f27350880 Mon Sep 17 00:00:00 2001 From: gitea_admin_user Date: Wed, 9 Apr 2025 20:08:58 +0000 Subject: [PATCH] Upload files to "/" --- flow_wrapper.py | 6 ++++-- generator.py | 3 ++- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/flow_wrapper.py b/flow_wrapper.py index cd6adeb..2ecf9cd 100644 --- a/flow_wrapper.py +++ b/flow_wrapper.py @@ -44,7 +44,8 @@ flow_name_safe = sanitize_name(FLOW_NAME) commit_id_safe = sanitize_name(COMMIT_ID_SHORT) # Construct the task queue name -TASK_QUEUE = f"{flow_name_safe}_{commit_id_safe}" +# TASK_QUEUE = f"{flow_name_safe}_{commit_id_safe}" +TASK_QUEUE = flow_name_safe # Import the default workflow module workflow_module_name = "workflow" # Hardcoded to the default module name 'workflow.py' @@ -55,7 +56,8 @@ except ImportError as e: # Get the workflow class # Assuming the workflow class is named as Workflow, e.g., HybridWorkflow -workflow_class_name = f"{flow_name_safe}_{commit_id_safe}" +# workflow_class_name = f"{flow_name_safe}_{commit_id_safe}" +workflow_class_name = flow_name_safe workflow_class = getattr(workflow_module, workflow_class_name, None) if not workflow_class: diff --git a/generator.py b/generator.py index 9c1b702..43980f5 100644 --- a/generator.py +++ b/generator.py @@ -44,7 +44,8 @@ FLOW_NAME = REPO_NAME + "_" + BRANCH_NAME flow_name_safe = sanitize_name(FLOW_NAME) commit_id_safe = sanitize_name(COMMIT_ID_SHORT) -workflow_class_name = f"{flow_name_safe}_{commit_id_safe}" +# workflow_class_name = f"{flow_name_safe}_{commit_id_safe}" +workflow_class_name = flow_name_safe def load_flow_definition(file_path): """Load the flow definition from a JSON file."""