Open a Dagster Pipes session

Reads bootstrap parameters from environment variables, initializes the message channel, and returns a PipesContext ready to use. When not running under Dagster (environment variables absent), returns a no-op NullPipesContext that logs to the console and silently ignores reports.

Usage

open_dagster_pipes()

Value

A PipesContext or NullPipesContext object.

Examples

if (FALSE) { # \dontrun{
ctx <- open_dagster_pipes()

threshold <- ctx$get_extra("threshold")
ctx$log(sprintf("Using threshold = %s", threshold), level = "INFO")

# ... do work ...

ctx$report_asset_materialization(
  metadata = list(
    row_count = pipes_metadata_value(1000L, "int")
  )
)
ctx$close()
} # }