Skip to content

Instantly share code, notes, and snippets.

@bstadlbauer

bstadlbauer/flyte_nested_failure.py Secret

Last active February 8, 2023 09:40
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save bstadlbauer/6680fccaa25154afe2d752ccc948c93e to your computer and use it in GitHub Desktop.
Save bstadlbauer/6680fccaa25154afe2d752ccc948c93e to your computer and use it in GitHub Desktop.
Download ZIP
Raw
flyte_nested_failure.py
from flytekit import workflow, task, LaunchPlan, dynamic
@task
def some_task():
print("Do something")
@dynamic
def dynamic_task():
for i in range(1):
some_task()
@workflow
def lauch_plan_workflow():
dynamic_task()
launch_plan = LaunchPlan.get_or_create(lauch_plan_workflow)
@workflow
def topelevel_workflow():
launch_plan()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment