From bc834e99f8e2d5e36278bb9f84ca57180f14947c Mon Sep 17 00:00:00 2001 From: MartinFoka Date: Thu, 7 Nov 2024 12:35:03 +0100 Subject: [PATCH] Exclude simulate_retryable_error from wf for system tests --- examples/simple_worker/workers/test_worker.py | 2 ++ examples/simple_worker/workers/test_workflow.py | 7 ------- 2 files changed, 2 insertions(+), 7 deletions(-) diff --git a/examples/simple_worker/workers/test_worker.py b/examples/simple_worker/workers/test_worker.py index 2e11d14..eb53641 100644 --- a/examples/simple_worker/workers/test_worker.py +++ b/examples/simple_worker/workers/test_worker.py @@ -210,6 +210,8 @@ def execute(self, worker_input: WorkerInput) -> TaskResult[WorkerOutput]: logs=['This is a log message from TaskResult.'] ) + # TODO: Not currently used in any workflow or test + # A new standalone workflow and test scenario should be created class SimulateRetryableErrorWorker(WorkerImpl): class WorkerDefinition(TaskDefinition): name: str = 'TEST_simulate_retryable_error' diff --git a/examples/simple_worker/workers/test_workflow.py b/examples/simple_worker/workers/test_workflow.py index 2e742fd..581574a 100644 --- a/examples/simple_worker/workers/test_workflow.py +++ b/examples/simple_worker/workers/test_workflow.py @@ -56,13 +56,6 @@ class WorkflowOutput(WorkflowImpl.WorkflowOutput): bytes: str def workflow_builder(self, workflow_inputs: WorkflowInput) -> None: - simulate_retryable_error_task = SimpleTask( - name=TestWorkers.SimulateRetryableErrorWorker, - task_reference_name='retryable_error', - input_parameters=SimpleTaskInputParameters(dict()) - ) - self.tasks.append(simulate_retryable_error_task) - simulate_logs_task = SimpleTask( name=TestWorkers.Logs, task_reference_name='logs',