AACFlow

Dagster

Orchestrate data pipelines and manage job runs with Dagster

Usage Instructions

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+.

Tools

dagster_launch_run

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
repositoryLocationNamestringYesNo description
repositoryNamestringYesNo description
jobNamestringYesNo description
runConfigJsonstringNoNo description
tagsstringNoNo description

Output

ParameterTypeDescription
runIdstringrunId output from the tool

dagster_get_run

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
runIdstringYesNo description

Output

ParameterTypeDescription
runIdstringrunId output from the tool
jobNamestringjobName output from the tool
statusstringstatus output from the tool
startTimenumberstartTime output from the tool
endTimenumberendTime output from the tool
runConfigYamlstringrunConfigYaml output from the tool
tagsjsontags output from the tool

dagster_get_run_logs

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
runIdstringYesNo description
afterCursorstringNoNo description
limitnumberNoNo description

Output

ParameterTypeDescription
eventsjsonevents output from the tool
typestringtype output from the tool
messagestringmessage output from the tool
timestampstringtimestamp output from the tool
levelstringlevel output from the tool
stepKeystringstepKey output from the tool
eventTypestringeventType output from the tool
cursorstringcursor output from the tool
hasMorebooleanhasMore output from the tool

dagster_list_runs

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
jobNamestringNoNo description
statusesstringNoNo description
limitnumberNoNo description

Output

ParameterTypeDescription
runsjsonruns output from the tool
runIdstringrunId output from the tool
jobNamestringjobName output from the tool
statusstringstatus output from the tool
tagsjsontags output from the tool
startTimenumberstartTime output from the tool
endTimenumberendTime output from the tool

dagster_list_jobs

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description

Output

ParameterTypeDescription
jobsjsonjobs output from the tool
namestringname output from the tool
repositoryNamestringrepositoryName output from the tool

dagster_reexecute_run

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
parentRunIdstringYesNo description
strategystringYesNo description

Output

ParameterTypeDescription
runIdstringrunId output from the tool

dagster_terminate_run

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
runIdstringYesNo description

Output

ParameterTypeDescription
successbooleansuccess output from the tool
runIdstringrunId output from the tool
messagestringmessage output from the tool

dagster_delete_run

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
runIdstringYesNo description

Output

ParameterTypeDescription
runIdstringrunId output from the tool

dagster_list_schedules

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
repositoryLocationNamestringYesNo description
repositoryNamestringYesNo description
scheduleStatusstringNoNo description

Output

ParameterTypeDescription
schedulesjsonschedules output from the tool
namestringname output from the tool
cronSchedulestringcronSchedule output from the tool
jobNamestringjobName output from the tool
statusstringstatus output from the tool
idstringid output from the tool
descriptionstringdescription output from the tool
executionTimezonestringexecutionTimezone output from the tool

dagster_start_schedule

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
repositoryLocationNamestringYesNo description
repositoryNamestringYesNo description
scheduleNamestringYesNo description

Output

ParameterTypeDescription
idstringid output from the tool
statusstringstatus output from the tool

dagster_stop_schedule

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
instigationStateIdstringYesNo description

Output

ParameterTypeDescription
idstringid output from the tool
statusstringstatus output from the tool

dagster_list_sensors

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
repositoryLocationNamestringYesNo description
repositoryNamestringYesNo description
sensorStatusstringNoNo description

Output

ParameterTypeDescription
sensorsjsonsensors output from the tool
namestringname output from the tool
sensorTypestringsensorType output from the tool
statusstringstatus output from the tool
idstringid output from the tool
descriptionstringdescription output from the tool

dagster_start_sensor

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
repositoryLocationNamestringYesNo description
repositoryNamestringYesNo description
sensorNamestringYesNo description

Output

ParameterTypeDescription
idstringid output from the tool
statusstringstatus output from the tool

dagster_stop_sensor

Input

ParameterTypeRequiredDescription
hoststringYesNo description
apiKeystringNoNo description
instigationStateIdstringYesNo description

Output

ParameterTypeDescription
idstringid output from the tool
statusstringstatus output from the tool

Auf dieser Seite

Heute mit dem Aufbau beginnen
Über 100 000 Entwickler vertrauen uns.
Die SaaS-Plattform zum Aufbau von KI-Agenten und für Ihre agentische Belegschaft.
Loslegen