Dusty Shapiro
11/10/2022, 8:46 PM@op
def upload_docs_to_s3():
foo
@job
def dbt_cli_docs():
dbt_docs_generate_op()
upload_docs_to_s3()
In this case, both ops try to run at the same time.
In any case, is there a simple way to set relationship of ops in general? Like:
op1 >> op2 >> op3
nickvazz
11/10/2022, 8:53 PMfrom the docs here
from 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)
yuhan
11/10/2022, 9:06 PMDusty Shapiro
11/10/2022, 9:09 PMScheduleDefinition
like a job?yuhan
11/10/2022, 9:25 PM@job