https://dagster.io/ logo
Title
m

Manny Schneck

12/05/2021, 7:44 AM
@op
def hi():
    return 'hello'

@graph
def foo():
    hi()

yeet =  hi.to_job()
Am I missing something? This looks isomorphic to the docs:
@graph
def calories():
    normalize_calories(download_csv())


calories_test_job = calories.to_job(
    resource_defs={"warehouse": local_sqlite_warehouse_resource}
)
calories_dev_job = calories.to_job(
    resource_defs={"warehouse": sqlalchemy_postgres_warehouse_resource}
)
But sadness:
scripts/end_to_end.py:727: in <module>
    yeet =  hi.to_job()
E   AttributeError: 'OpDefinition' object has no attribute 'to_job'