Mycchaka Kleinbort
03/09/2023, 4:17 PMfrom .repository import my_dagster_project
and repository.py
was:
from dagster import load_assets_from_package_module, repository
from my_dagster_project import assets
@repository
def my_dagster_project():
return [load_assets_from_package_module(assets)]
I changed that to
from .repository import my_dagster_project
and
from dagster import Definitions, load_assets_from_package_module
from my_dagster_project import assets
all_assets = load_assets_from_package_module(assets)
defs = Definitions(
assets=all_assets,
schedules=[assets.dg_test_schedule.update_job_schedule]
)
And now things work
However, this took me far too long 😂 - it should have been flagged as a gotcha somewhere IMO