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',