Skip to main content

DagsterOrchestration

What it is​

  • A small wrapper around Dagster’s dagster.Definitions, implementing/deriving from naas_abi_core.orchestrations.Orchestrations.
  • Provides a stored Definitions object and a convenience constructor for an empty Dagster setup.

Public API​

  • class DagsterOrchestration(Orchestrations)
    • __init__(definitions: dagster.Definitions)
      • Stores the provided Dagster Definitions instance.
    • definitions -> dagster.Definitions (property)
      • Returns the stored Definitions.
    • New() -> DagsterOrchestration (classmethod)
      • Returns a new instance initialized with Definitions() (empty definitions).

Configuration/Dependencies​

  • Dependencies
    • dagster.Definitions
    • naas_abi_core.orchestrations.Orchestrations.Orchestrations (base class)

Usage​

from naas_abi_core.orchestrations.DagsterOrchestration import DagsterOrchestration

orch = DagsterOrchestration.New()
defs = orch.definitions  # dagster.Definitions instance
print(defs)

Caveats​

  • New() creates an empty Definitions(); jobs/assets/resources are not configured here.