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'