Signed-off-by: -LAN- <laipz8200@outlook.com>tags/1.4.2
| @@ -140,7 +140,7 @@ class AdvancedChatAppRunner(WorkflowBasedAppRunner): | |||
| SystemVariableKey.DIALOGUE_COUNT: self._dialogue_count, | |||
| SystemVariableKey.APP_ID: app_config.app_id, | |||
| SystemVariableKey.WORKFLOW_ID: app_config.workflow_id, | |||
| SystemVariableKey.WORKFLOW_RUN_ID: self.application_generate_entity.workflow_run_id, | |||
| SystemVariableKey.WORKFLOW_EXECUTION_ID: self.application_generate_entity.workflow_run_id, | |||
| } | |||
| # init variable pool | |||
| @@ -124,7 +124,7 @@ class AdvancedChatAppGenerateTaskPipeline: | |||
| SystemVariableKey.DIALOGUE_COUNT: dialogue_count, | |||
| SystemVariableKey.APP_ID: application_generate_entity.app_config.app_id, | |||
| SystemVariableKey.WORKFLOW_ID: workflow.id, | |||
| SystemVariableKey.WORKFLOW_RUN_ID: application_generate_entity.workflow_run_id, | |||
| SystemVariableKey.WORKFLOW_EXECUTION_ID: application_generate_entity.workflow_run_id, | |||
| }, | |||
| workflow_info=CycleManagerWorkflowInfo( | |||
| workflow_id=workflow.id, | |||
| @@ -95,7 +95,7 @@ class WorkflowAppRunner(WorkflowBasedAppRunner): | |||
| SystemVariableKey.USER_ID: user_id, | |||
| SystemVariableKey.APP_ID: app_config.app_id, | |||
| SystemVariableKey.WORKFLOW_ID: app_config.workflow_id, | |||
| SystemVariableKey.WORKFLOW_RUN_ID: self.application_generate_entity.workflow_execution_id, | |||
| SystemVariableKey.WORKFLOW_EXECUTION_ID: self.application_generate_entity.workflow_execution_id, | |||
| } | |||
| variable_pool = VariablePool( | |||
| @@ -113,7 +113,7 @@ class WorkflowAppGenerateTaskPipeline: | |||
| SystemVariableKey.USER_ID: user_session_id, | |||
| SystemVariableKey.APP_ID: application_generate_entity.app_config.app_id, | |||
| SystemVariableKey.WORKFLOW_ID: workflow.id, | |||
| SystemVariableKey.WORKFLOW_RUN_ID: application_generate_entity.workflow_execution_id, | |||
| SystemVariableKey.WORKFLOW_EXECUTION_ID: application_generate_entity.workflow_execution_id, | |||
| }, | |||
| workflow_info=CycleManagerWorkflowInfo( | |||
| workflow_id=workflow.id, | |||
| @@ -13,4 +13,4 @@ class SystemVariableKey(StrEnum): | |||
| DIALOGUE_COUNT = "dialogue_count" | |||
| APP_ID = "app_id" | |||
| WORKFLOW_ID = "workflow_id" | |||
| WORKFLOW_RUN_ID = "workflow_run_id" | |||
| WORKFLOW_EXECUTION_ID = "workflow_run_id" | |||
| @@ -65,7 +65,7 @@ class WorkflowCycleManager: | |||
| # init workflow run | |||
| # TODO: This workflow_run_id should always not be None, maybe we can use a more elegant way to handle this | |||
| execution_id = str(self._workflow_system_variables.get(SystemVariableKey.WORKFLOW_RUN_ID) or uuid4()) | |||
| execution_id = str(self._workflow_system_variables.get(SystemVariableKey.WORKFLOW_EXECUTION_ID) or uuid4()) | |||
| execution = WorkflowExecution.new( | |||
| id_=execution_id, | |||
| workflow_id=self._workflow_info.workflow_id, | |||
| @@ -73,7 +73,7 @@ def real_workflow_system_variables(): | |||
| SystemVariableKey.USER_ID: "test-user-id", | |||
| SystemVariableKey.APP_ID: "test-app-id", | |||
| SystemVariableKey.WORKFLOW_ID: "test-workflow-id", | |||
| SystemVariableKey.WORKFLOW_RUN_ID: "test-workflow-run-id", | |||
| SystemVariableKey.WORKFLOW_EXECUTION_ID: "test-workflow-run-id", | |||
| } | |||