Skip to content

DagsterCodeLocation

kedro_dagster.translator.DagsterCodeLocation dataclass

A typed container for all artifacts that make up a Dagster code location.

Attributes

Name Type Description
named_assets dict[str, AssetSpec | AssetsDefinition]

Dictionary of named Dagster assets.
named_resources dict[str, ResourceDefinition]

Dictionary of named Dagster resources.
named_jobs dict[str, JobDefinition]

Dictionary of named Dagster jobs.
named_executors dict[str, ExecutorDefinition]

Dictionary of named Dagster executors.
named_schedules dict[str, ScheduleDefinition]

Dictionary of named Dagster schedules.
named_sensors dict[str, SensorDefinition]

Dictionary of named Dagster sensors.
named_loggers dict[str, LoggerDefinition]

Dictionary of named Dagster loggers.

See Also

kedro_dagster.translator.KedroProjectTranslator.to_dagster : Produces instances of this dataclass.

Source Code

View on GitHub

Show/Hide source 
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
@dataclass
class DagsterCodeLocation:
    """A typed container for all artifacts that make up a Dagster code location.

    Attributes
    ----------
    named_assets : dict[str, AssetSpec | AssetsDefinition]
        Dictionary of named Dagster assets.
    named_resources : dict[str, ResourceDefinition]
        Dictionary of named Dagster resources.
    named_jobs : dict[str, JobDefinition]
        Dictionary of named Dagster jobs.
    named_executors : dict[str, ExecutorDefinition]
        Dictionary of named Dagster executors.
    named_schedules : dict[str, ScheduleDefinition]
        Dictionary of named Dagster schedules.
    named_sensors : dict[str, SensorDefinition]
        Dictionary of named Dagster sensors.
    named_loggers : dict[str, LoggerDefinition]
        Dictionary of named Dagster loggers.

    See Also
    --------
    `kedro_dagster.translator.KedroProjectTranslator.to_dagster` :
        Produces instances of this dataclass.
    """

    named_assets: dict[str, dg.AssetSpec | dg.AssetsDefinition]
    named_resources: dict[str, dg.ResourceDefinition]
    named_jobs: dict[str, dg.JobDefinition]
    named_executors: dict[str, dg.ExecutorDefinition]
    named_schedules: dict[str, dg.ScheduleDefinition]
    named_sensors: dict[str, dg.SensorDefinition]
    named_loggers: dict[str, dg.LoggerDefinition]