Rashid Ahmed
07/28/2023, 8:47 AMfrom dagster import graph, op
@op
def return_one(context) -> int:
return 1
@op
def add_one(context, number: int):
return number + 1
@op
def adder(context, a: int, b: int) -> int:
return a + b
@graph
def inputs_and_outputs():
value = return_one()
a = add_one(value)
b = add_one(value)
adder(a, b)
Zach
07/28/2023, 2:56 PMadd_one()
could execute before return_one()
does as it's dependent on the output of return_one()
, which is how Dagster infers its dependencies.