Shriram Holla
05/24/2022, 4:32 PM@job
def myJob():
op1()
op2()
op2 should run only after op1sean
05/24/2022, 4:35 PMop1
as a dep of op2
but no data is passed between them.Qwame
05/24/2022, 4:36 PMstart_after
argument:
@job
def myjob():
op1(start_after=op2())
sean
05/24/2022, 4:45 PMstart_after
keyword arg, this is not a dagster core API so you can’t use it for arbitrary ops. Nothing
is the general API to use.Qwame
05/24/2022, 4:47 PMStephen Bailey
05/24/2022, 5:13 PMShriram Holla
05/24/2022, 7:26 PMUserWarning: Error loading repository location dagster_join.py:dagster.core.errors.DagsterInvalidDefinitionError: In @job myJob, received invalid type <class 'NoneType'> for input "start" (passed by keyword) in op invocation "op2". Must pass the output from previous node invocations or inputs to the composition function as inputs when invoking nodes during composition.
sean
05/24/2022, 7:55 PMShriram Holla
05/24/2022, 8:05 PMsean
05/24/2022, 9:14 PMShriram Holla
05/25/2022, 1:15 PM