Skip to content
This repository was archived by the owner on Apr 30, 2025. It is now read-only.

Commit bdc53e4

Browse files
authored
Exclude simulate_retryable_error from wf for system tests (#78)
1 parent a25ebd9 commit bdc53e4

File tree

2 files changed

+2
-7
lines changed

2 files changed

+2
-7
lines changed

examples/simple_worker/workers/test_worker.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -210,6 +210,8 @@ def execute(self, worker_input: WorkerInput) -> TaskResult[WorkerOutput]:
210210
logs=['This is a log message from TaskResult.']
211211
)
212212

213+
# TODO: Not currently used in any workflow or test
214+
# A new standalone workflow and test scenario should be created
213215
class SimulateRetryableErrorWorker(WorkerImpl):
214216
class WorkerDefinition(TaskDefinition):
215217
name: str = 'TEST_simulate_retryable_error'

examples/simple_worker/workers/test_workflow.py

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -56,13 +56,6 @@ class WorkflowOutput(WorkflowImpl.WorkflowOutput):
5656
bytes: str
5757

5858
def workflow_builder(self, workflow_inputs: WorkflowInput) -> None:
59-
simulate_retryable_error_task = SimpleTask(
60-
name=TestWorkers.SimulateRetryableErrorWorker,
61-
task_reference_name='retryable_error',
62-
input_parameters=SimpleTaskInputParameters(dict())
63-
)
64-
self.tasks.append(simulate_retryable_error_task)
65-
6659
simulate_logs_task = SimpleTask(
6760
name=TestWorkers.Logs,
6861
task_reference_name='logs',

0 commit comments

Comments
 (0)