Orchestrate data pipelines and manage job runs with Dagster
Dagster is a AACFlow integration in the Observability category. AACFlow is the AI workspace where teams build and deploy AI agents. AACFlow's Dagster integration provides 19 tools that AI agents can use inside AACFlow's visual workflow builder. Dagster connects with an API key. Get started at aacflow.io.
Zuletzt aktualisiert
Connect to a Dagster instance to launch job runs, monitor run status, list available jobs across repositories, terminate or delete runs, reexecute failed runs, fetch run logs, and manage schedules and sensors. API token only required for Dagster+.
Registrieren Sie sich in Sekunden auf aacflow.io. Ihr Workspace ist sofort einsatzbereit.
Öffnen Sie Ihren Workspace, ziehen Sie einen Dagster-Block in den Workflow-Builder und fügen Sie Ihren Dagster-API-Schlüssel ein.
Wählen Sie das benötigte Tool, binden Sie einen KI-Agenten für Reasoning oder Datentransformation ein und starten Sie. Ihre Dagster-Automatisierung ist live.
Einsatzbereite Vorlagen mit Dagster. Klicken Sie auf eine, um sie sofort zu erstellen.
19 Dagster-Tools für AACFlow-Agenten verfügbar.
Launch a job run on a Dagster instance.
Get the status and details of a Dagster run by its ID.
Fetch execution event logs for a Dagster run.
List Dagster runs with optional filters by job name, status, and creation-time range, plus cursor pagination.
List all jobs across repositories in a Dagster instance.
Reexecute an existing Dagster run, optionally resuming only from failed steps.
Terminate an in-progress Dagster run.
Permanently delete a Dagster run record.
List all schedules in a Dagster repository, optionally filtered by status.
Enable (start) a schedule in a Dagster repository.
Disable (stop) a running schedule in Dagster.
List all sensors in a Dagster repository, optionally filtered by status.
Enable (start) a sensor in a Dagster repository.
Disable (stop) a running sensor in Dagster.
List assets tracked by a Dagster instance, optionally filtered by key prefix.
Get an asset definition and its latest materialization by asset key.
Materialize selected assets by launching their asset job with an asset selection.
Report an external (runless) materialization or observation for an asset.
DESTRUCTIVE: permanently wipes ALL materialization history (every partition) for an asset. This cannot be undone.
AACFlow's Dagster integration adds 19 tools to the AI agents you build in AACFlow's visual workflow builder. Orchestrate data pipelines and manage job runs with Dagster.
