Skip to content

definitions

Dagster definition entry point for orchestrating the example dbt project.

This module wires the dbt project metadata into the :class:DagsterDbtFactory so that the resulting :class:dagster.Definitions object exposes assets, sensors, and resources consistent with a real deployment.

defs()

@definitions decorator will provides lazy loading so that the assets are only instantiated when needed. Will be automatically detected and loaded by the load_defs function in the root definitions file.

Returns:

Type Description
Definitions

dagster.Definitions: The definitions explicitly available and loadable by Dagster tools.
Source code in data_foundation/defs/dbt/definitions.py 
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
@definitions
def defs() -> Definitions:
    """@definitions decorator will provides lazy loading so that the assets are only
    instantiated when needed. Will be automatically detected and loaded by the load_defs
    function in the root definitions file.

    Returns:
        dagster.Definitions: The definitions explicitly available and loadable by
            Dagster tools.

    """
    project_dir = Path(__file__).joinpath(*[".."] * 5, "dbt/").resolve()
    state_path = "state/"


    def dbt() -> DbtProject:
        """Instantiate a :class:`DbtProject` with environment-aware configuration.

        Returns:
            dagster_dbt.DbtProject: The fully configured dbt project instance that
                Dagster will interact with when executing assets. The helper runs
                ``prepare_if_dev`` to ensure the project is ready for local execution
                when targeting a development profile.
        """
        project = DbtProject(
            project_dir=project_dir,
            packaged_project_dir=project_dir,
            target=os.getenv("TARGET", "dev"),
            state_path=state_path,
            profile="dbt",
        )
        # project.prepare_if_dev()
        return project

    return Factory.build_definitions(dbt)