Trigger Bolt schedules from Dagster

Run Bolt schedules as Dagster assets using Paradime’s fork of the dagster-dbt integration. It loads a Bolt schedule as Dagster assets, executes the schedule, and retrieves its artifacts, so your Bolt runs are part of your Dagster orchestration.

You need a Paradime API key with the Bolt schedules admin capability, plus its secret and the API endpoint. See API keys.

Install

Install the integration from GitHub:

pip install -e git+https://github.com/paradime-io/paradime-dagster-dbt.git#egg=dagster_dbt

For a cloud deployment, pin it in setup.py:

"dagster-dbt @ git+https://github.com/paradime-io/paradime-dagster-dbt.git@1.5.9#egg=dagster_dbt"

Load a Bolt schedule as assets

Configure the Paradime connection with your API credentials, then load a schedule as Dagster assets:

import os

from dagster_dbt import ParadimeClientResource, load_assets_from_paradime_schedule

paradime = ParadimeClientResource(
    api_key=os.getenv("PARADIME_API_KEY"),
    api_secret=os.getenv("PARADIME_API_SECRET"),
    paradime_api_host=os.getenv("PARADIME_API_HOST"),
)

paradime_assets = load_assets_from_paradime_schedule(
    paradime=paradime,
    schedule_name="daily_run",  # the Bolt schedule name (no spaces)
)

load_assets_from_paradime_schedule executes the schedule and retrieves its artifacts through the Dagster asset model, so the Bolt run appears as materialized assets in Dagster.

Paradime Dagster integration

The dagster-dbt fork with ParadimeClientResource and load_assets_from_paradime_schedule.

Schedule Anatomy

Deploy Schedules

Managing Schedules

CI/CD

Trigger Bolt schedules from Dagster

Install

Load a Bolt schedule as assets

Paradime Dagster integration

​Install

​Load a Bolt schedule as assets

Paradime Dagster integration

Install

Load a Bolt schedule as assets