@@ -15,25 +15,29 @@ This project implements a [Model Context Protocol](https://modelcontextprotocol.
15
15
| Get DAG Details | ` /api/v1/dags/{dag_id} ` | ✅ |
16
16
| Pause DAG | ` /api/v1/dags/{dag_id} ` | ✅ |
17
17
| Unpause DAG | ` /api/v1/dags/{dag_id} ` | ✅ |
18
- | Update DAG | ` /api/v1/dags/{dag_id} ` | ✅ | |
18
+ | Update DAG | ` /api/v1/dags/{dag_id} ` | ✅ |
19
19
| Delete DAG | ` /api/v1/dags/{dag_id} ` | ✅ |
20
+ | Get DAG Source | ` /api/v1/dagSources/{file_token} ` | ✅ |
21
+ | Patch Multiple DAGs | ` /api/v1/dags ` | ✅ |
22
+ | Reparse DAG File | ` /api/v1/dagSources/{file_token}/reparse ` | ✅ |
20
23
| ** DAG Runs** | | |
21
24
| List DAG Runs | ` /api/v1/dags/{dag_id}/dagRuns ` | ✅ |
22
25
| Create DAG Run | ` /api/v1/dags/{dag_id}/dagRuns ` | ✅ |
23
26
| Get DAG Run Details | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id} ` | ✅ |
24
27
| Update DAG Run | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id} ` | ✅ |
25
28
| Delete DAG Run | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id} ` | ✅ |
29
+ | Get DAG Runs Batch | ` /api/v1/dags/~/dagRuns/list ` | ✅ |
30
+ | Clear DAG Run | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/clear ` | ✅ |
31
+ | Set DAG Run Note | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/setNote ` | ✅ |
32
+ | Get Upstream Dataset Events | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/upstreamDatasetEvents ` | ✅ |
26
33
| ** Tasks** | | |
27
34
| List DAG Tasks | ` /api/v1/dags/{dag_id}/tasks ` | ✅ |
28
35
| Get Task Details | ` /api/v1/dags/{dag_id}/tasks/{task_id} ` | ✅ |
29
36
| Get Task Instance | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} ` | ✅ |
30
37
| List Task Instances | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances ` | ✅ |
31
38
| Update Task Instance | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} ` | ✅ |
32
- | ** System** | | |
33
- | Get Import Errors | ` /api/v1/importErrors ` | ✅ |
34
- | Get Import Error Details | ` /api/v1/importErrors/{import_error_id} ` | ✅ |
35
- | Get Health Status | ` /api/v1/health ` | ✅ |
36
- | Get Version | ` /api/v1/version ` | ✅ |
39
+ | Clear Task Instances | ` /api/v1/dags/{dag_id}/clearTaskInstances ` | ✅ |
40
+ | Set Task Instances State | ` /api/v1/dags/{dag_id}/updateTaskInstancesState ` | ✅ |
37
41
| ** Variables** | | |
38
42
| List Variables | ` /api/v1/variables ` | ✅ |
39
43
| Create Variable | ` /api/v1/variables ` | ✅ |
@@ -46,6 +50,45 @@ This project implements a [Model Context Protocol](https://modelcontextprotocol.
46
50
| Get Connection | ` /api/v1/connections/{connection_id} ` | ✅ |
47
51
| Update Connection | ` /api/v1/connections/{connection_id} ` | ✅ |
48
52
| Delete Connection | ` /api/v1/connections/{connection_id} ` | ✅ |
53
+ | Test Connection | ` /api/v1/connections/test ` | ✅ |
54
+ | ** Pools** | | |
55
+ | List Pools | ` /api/v1/pools ` | ✅ |
56
+ | Create Pool | ` /api/v1/pools ` | ✅ |
57
+ | Get Pool | ` /api/v1/pools/{pool_name} ` | ✅ |
58
+ | Update Pool | ` /api/v1/pools/{pool_name} ` | ✅ |
59
+ | Delete Pool | ` /api/v1/pools/{pool_name} ` | ✅ |
60
+ | ** XComs** | | |
61
+ | List XComs | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries ` | ✅ |
62
+ | Get XCom Entry | ` /api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries/{xcom_key} ` | ✅ |
63
+ | ** Datasets** | | |
64
+ | List Datasets | ` /api/v1/datasets ` | ✅ |
65
+ | Get Dataset | ` /api/v1/datasets/{uri} ` | ✅ |
66
+ | Get Dataset Events | ` /api/v1/datasetEvents ` | ✅ |
67
+ | Create Dataset Event | ` /api/v1/datasetEvents ` | ✅ |
68
+ | Get DAG Dataset Queued Event | ` /api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents/{uri} ` | ✅ |
69
+ | Get DAG Dataset Queued Events | ` /api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents ` | ✅ |
70
+ | Delete DAG Dataset Queued Event | ` /api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents/{uri} ` | ✅ |
71
+ | Delete DAG Dataset Queued Events | ` /api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents ` | ✅ |
72
+ | Get Dataset Queued Events | ` /api/v1/datasets/{uri}/dagRuns/queued/datasetEvents ` | ✅ |
73
+ | Delete Dataset Queued Events | ` /api/v1/datasets/{uri}/dagRuns/queued/datasetEvents ` | ✅ |
74
+ | ** Monitoring** | | |
75
+ | Get Health | ` /api/v1/health ` | ✅ |
76
+ | ** DAG Stats** | | |
77
+ | Get DAG Stats | ` /api/v1/dags/statistics ` | ✅ |
78
+ | ** Config** | | |
79
+ | Get Config | ` /api/v1/config ` | ✅ |
80
+ | ** Plugins** | | |
81
+ | Get Plugins | ` /api/v1/plugins ` | ✅ |
82
+ | ** Providers** | | |
83
+ | List Providers | ` /api/v1/providers ` | ✅ |
84
+ | ** Event Logs** | | |
85
+ | List Event Logs | ` /api/v1/eventLogs ` | ✅ |
86
+ | Get Event Log | ` /api/v1/eventLogs/{event_log_id} ` | ✅ |
87
+ | ** System** | | |
88
+ | Get Import Errors | ` /api/v1/importErrors ` | ✅ |
89
+ | Get Import Error Details | ` /api/v1/importErrors/{import_error_id} ` | ✅ |
90
+ | Get Health Status | ` /api/v1/health ` | ✅ |
91
+ | Get Version | ` /api/v1/version ` | ✅ |
49
92
50
93
## Setup
51
94
0 commit comments