May Bohadana
03/28/2023, 8:51 AMsean
03/28/2023, 2:54 PMimport time
from dagster import Definitions, job, op
@op
def alpha():
time.sleep(5)
return 1
@op
def beta():
raise Exception()
@op
def delta(x):
return x + 1
@job
def foo_job():
delta(alpha())
beta()
defs = Definitions(jobs=[foo_job])
May Bohadana
03/28/2023, 3:45 PMsean
03/28/2023, 4:34 PMdelta
is launched well after beta
already failed (because alpha
sleeps for 5 seconds)May Bohadana
03/28/2023, 5:17 PMsean
03/28/2023, 5:47 PMMay Bohadana
03/29/2023, 8:04 AM