workflow-manager.app.api.dagster_queries#

GraphQL queries for interacting with Dagster.

Attributes#

DAGSTER_URL

Functions#

list_dagster_jobs(→ list[dict])

List all available Dagster jobs.

parse_job_id(→ tuple[str, str, str])

Parse the job ID into its components.

Module Contents#

workflow-manager.app.api.dagster_queries.DAGSTER_URL = 'http://dagster-webserver:3000/dagster/graphql'#
workflow-manager.app.api.dagster_queries.list_dagster_jobs() → list[dict][source]#

List all available Dagster jobs.

workflow-manager.app.api.dagster_queries.parse_job_id(job_id: str) → tuple[str, str, str][source]#

Parse the job ID into its components.