abundant-judge-84756
05/01/2024, 10:06 AMglamorous-carpet-83516
05/01/2024, 2:39 PMabundant-judge-84756
05/01/2024, 2:54 PM@task
def final_task():
return 5
@task
def no_task():
return 0
@workflow
def my_subworkflow() -> int:
do_some_complicated_tasks()
return final_task()
@workflow
def my_workflow(some_condition: bool) -> int:
result = (
conditional("my_workflow_switch")
.if_(some_condition.is_true())
.then(my_subworkflow())
.else_()
.then(no_task())
)
return result
@workflow_patch(my_subworkflow)
@task_patch(no_task)
def test_my_workflow_invokes_expected_condition(
task_mock,
subworkflow_mock,
):
my_workflow(True)
subworkflow_mock.assert_called_once()
task_mock.assert_not_called()
glamorous-carpet-83516
05/02/2024, 4:27 AM@workflow_patch(my_subworkflow)I believe itβs doable. mind creating an issue. [flyte-core] contributions are welcome
user
05/02/2024, 4:27 AMabundant-judge-84756
05/02/2024, 8:26 AMrich-flower-81699
06/04/2024, 7:59 PMfreezing-airport-6809
abundant-judge-84756
06/05/2024, 9:03 AMfreezing-airport-6809