Hi, is there a way to stop the wf with *success* a...
# flyte-supporti
important-hamburger-34837
08/07/2024, 4:23 PMHi, is there a way to stop the wf with success after some task and skip remaining tasks without doing a conditional on every following task ?
g
glamorous-carpet-83516
08/08/2024, 7:25 AMhow do you determine when to not skip the tasks?
glamorous-carpet-83516
08/08/2024, 7:25 AMhow does your workflow look like, could you a simple example?
i
important-hamburger-34837
08/08/2024, 7:26 AMI have a task that checks input files.. if no files were found, i want the wf to stop .
important-hamburger-34837
08/08/2024, 7:27 AMNo subworkflows were used
g
glamorous-carpet-83516
08/08/2024, 7:30 AMhow about
Copy code
@workflow
def subwf(file_exist: bool) -> typing.Optional[float]:
return (
conditional("test")
.if_(file_exist is True)
.then(other_wf(....))
.else_()
.then(echo())
)
@workflow
def wf():
file_exist = check_input_files(...)
subwf(file_exist=file_exist)glamorous-carpet-83516
08/08/2024, 7:30 AMecho is a noop task, it does nothing
glamorous-carpet-83516
08/08/2024, 7:31 AMI have a pr to add this echo task to flytekit. https://github.com/flyteorg/flytekit/pull/2654
glamorous-carpet-83516
08/08/2024, 7:31 AMyou could create a dummy task for now before we merge that.
i
important-hamburger-34837
08/08/2024, 7:31 AMYeah i remember we spoke about this few weeks ago 😅 ..
So subwf it is ..
g
glamorous-carpet-83516
08/08/2024, 7:32 AMoh cool, I forgot, sorry.
2 Views