Skip to content

Commit d12a10d

Browse files
authored
Prepare release 2.2.0 (#36)
Auto-generated code from Airflow 2.2.2
1 parent f8d7f95 commit d12a10d

File tree

314 files changed

+15303
-4557
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

314 files changed

+15303
-4557
lines changed

airflow_client/.openapi-generator-ignore

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1,19 +1,3 @@
1-
# Licensed to the Apache Software Foundation (ASF) under one
2-
# or more contributor license agreements. See the NOTICE file
3-
# distributed with this work for additional information
4-
# regarding copyright ownership. The ASF licenses this file
5-
# to you under the Apache License, Version 2.0 (the
6-
# "License"); you may not use this file except in compliance
7-
# with the License. You may obtain a copy of the License at
8-
#
9-
# http://www.apache.org/licenses/LICENSE-2.0
10-
#
11-
# Unless required by applicable law or agreed to in writing,
12-
# software distributed under the License is distributed on an
13-
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14-
# KIND, either express or implied. See the License for the
15-
# specific language governing permissions and limitations
16-
# under the License.
171
.travis.yml
182
git_push.sh
193
.gitlab-ci.yml

airflow_client/.openapi-generator/FILES

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ client/model/connection_all_of.py
3939
client/model/connection_collection.py
4040
client/model/connection_collection_all_of.py
4141
client/model/connection_collection_item.py
42+
client/model/connection_test.py
4243
client/model/cron_expression.py
4344
client/model/dag.py
4445
client/model/dag_collection.py
@@ -93,6 +94,7 @@ client/model/task_instance_reference_collection.py
9394
client/model/task_state.py
9495
client/model/time_delta.py
9596
client/model/trigger_rule.py
97+
client/model/update_dag_run_state.py
9698
client/model/update_task_instances_state.py
9799
client/model/user.py
98100
client/model/user_all_of.py
@@ -133,6 +135,7 @@ docs/ConnectionApi.md
133135
docs/ConnectionCollection.md
134136
docs/ConnectionCollectionAllOf.md
135137
docs/ConnectionCollectionItem.md
138+
docs/ConnectionTest.md
136139
docs/CronExpression.md
137140
docs/DAG.md
138141
docs/DAGApi.md
@@ -198,6 +201,7 @@ docs/TaskInstanceReferenceCollection.md
198201
docs/TaskState.md
199202
docs/TimeDelta.md
200203
docs/TriggerRule.md
204+
docs/UpdateDagRunState.md
201205
docs/UpdateTaskInstancesState.md
202206
docs/User.md
203207
docs/UserAllOf.md
@@ -239,6 +243,7 @@ test/test_connection_api.py
239243
test/test_connection_collection.py
240244
test/test_connection_collection_all_of.py
241245
test/test_connection_collection_item.py
246+
test/test_connection_test.py
242247
test/test_cron_expression.py
243248
test/test_dag.py
244249
test/test_dag_api.py
@@ -304,6 +309,7 @@ test/test_task_instance_reference_collection.py
304309
test/test_task_state.py
305310
test/test_time_delta.py
306311
test/test_trigger_rule.py
312+
test/test_update_dag_run_state.py
307313
test/test_update_task_instances_state.py
308314
test/test_user.py
309315
test/test_user_all_of.py
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
5.1.1
1+
5.3.0

airflow_client/README.md

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ Note that you will need to pass credentials data.
143143

144144
For e.g., here is how to pause a DAG with [curl](https://curl.haxx.se/), when basic authorization is used:
145145
```bash
146-
curl -X POST 'https://example.com/api/v1/dags/{dag_id}?update_mask=is_paused' \\
146+
curl -X PATCH 'https://example.com/api/v1/dags/{dag_id}?update_mask=is_paused' \\
147147
-H 'Content-Type: application/json' \\
148148
--user \"username:password\" \\
149149
-d '{
@@ -228,7 +228,7 @@ server is unwilling to supply a default representation.
228228
## AlreadyExists
229229

230230
The request could not be completed due to a conflict with the current state of the target
231-
resource, meaning that the resource already exists
231+
resource, e.g. the resource it tries to create already exists.
232232

233233
## Unknown
234234

@@ -239,7 +239,7 @@ fulfilling the request.
239239
This Python package is automatically generated by the [OpenAPI Generator](https://openapi-generator.tech) project:
240240

241241
- API version: 1.0.0
242-
- Package version: 2.1.0
242+
- Package version: 2.2.0
243243
- Build package: org.openapitools.codegen.languages.PythonClientCodegen
244244
For more information, please visit [https://airflow.apache.org](https://airflow.apache.org)
245245

@@ -331,6 +331,8 @@ Class | Method | HTTP request | Description
331331
*ConnectionApi* | [**get_connections**](docs/ConnectionApi.md#get_connections) | **GET** /connections | List connections
332332
*ConnectionApi* | [**patch_connection**](docs/ConnectionApi.md#patch_connection) | **PATCH** /connections/{connection_id} | Update a connection
333333
*ConnectionApi* | [**post_connection**](docs/ConnectionApi.md#post_connection) | **POST** /connections | Create a connection
334+
*ConnectionApi* | [**test_connection**](docs/ConnectionApi.md#test_connection) | **POST** /connections/test | Test a connection
335+
*DAGApi* | [**delete_dag**](docs/DAGApi.md#delete_dag) | **DELETE** /dags/{dag_id} | Delete a DAG
334336
*DAGApi* | [**get_dag**](docs/DAGApi.md#get_dag) | **GET** /dags/{dag_id} | Get basic information about a DAG
335337
*DAGApi* | [**get_dag_details**](docs/DAGApi.md#get_dag_details) | **GET** /dags/{dag_id}/details | Get a simplified representation of DAG
336338
*DAGApi* | [**get_dag_source**](docs/DAGApi.md#get_dag_source) | **GET** /dagSources/{file_token} | Get a source code
@@ -345,6 +347,7 @@ Class | Method | HTTP request | Description
345347
*DAGRunApi* | [**get_dag_runs**](docs/DAGRunApi.md#get_dag_runs) | **GET** /dags/{dag_id}/dagRuns | List DAG runs
346348
*DAGRunApi* | [**get_dag_runs_batch**](docs/DAGRunApi.md#get_dag_runs_batch) | **POST** /dags/~/dagRuns/list | List DAG runs (batch)
347349
*DAGRunApi* | [**post_dag_run**](docs/DAGRunApi.md#post_dag_run) | **POST** /dags/{dag_id}/dagRuns | Trigger a new DAG run
350+
*DAGRunApi* | [**update_dag_run_state**](docs/DAGRunApi.md#update_dag_run_state) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id} | Modify a DAG run
348351
*EventLogApi* | [**get_event_log**](docs/EventLogApi.md#get_event_log) | **GET** /eventLogs/{event_log_id} | Get a log entry
349352
*EventLogApi* | [**get_event_logs**](docs/EventLogApi.md#get_event_logs) | **GET** /eventLogs | List log entries
350353
*ImportErrorApi* | [**get_import_error**](docs/ImportErrorApi.md#get_import_error) | **GET** /importErrors/{import_error_id} | Get an import error
@@ -369,8 +372,11 @@ Class | Method | HTTP request | Description
369372
*TaskInstanceApi* | [**get_task_instance**](docs/TaskInstanceApi.md#get_task_instance) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} | Get a task instance
370373
*TaskInstanceApi* | [**get_task_instances**](docs/TaskInstanceApi.md#get_task_instances) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances | List task instances
371374
*TaskInstanceApi* | [**get_task_instances_batch**](docs/TaskInstanceApi.md#get_task_instances_batch) | **POST** /dags/~/dagRuns/~/taskInstances/list | List task instances (batch)
375+
*UserApi* | [**delete_user**](docs/UserApi.md#delete_user) | **DELETE** /users/{username} | Delete a user
372376
*UserApi* | [**get_user**](docs/UserApi.md#get_user) | **GET** /users/{username} | Get a user
373377
*UserApi* | [**get_users**](docs/UserApi.md#get_users) | **GET** /users | List users
378+
*UserApi* | [**patch_user**](docs/UserApi.md#patch_user) | **PATCH** /users/{username} | Update a user
379+
*UserApi* | [**post_user**](docs/UserApi.md#post_user) | **POST** /users | Create a user
374380
*VariableApi* | [**delete_variable**](docs/VariableApi.md#delete_variable) | **DELETE** /variables/{variable_key} | Delete a variable
375381
*VariableApi* | [**get_variable**](docs/VariableApi.md#get_variable) | **GET** /variables/{variable_key} | Get a variable
376382
*VariableApi* | [**get_variables**](docs/VariableApi.md#get_variables) | **GET** /variables | List variables
@@ -398,6 +404,7 @@ Class | Method | HTTP request | Description
398404
- [ConnectionCollection](docs/ConnectionCollection.md)
399405
- [ConnectionCollectionAllOf](docs/ConnectionCollectionAllOf.md)
400406
- [ConnectionCollectionItem](docs/ConnectionCollectionItem.md)
407+
- [ConnectionTest](docs/ConnectionTest.md)
401408
- [CronExpression](docs/CronExpression.md)
402409
- [DAG](docs/DAG.md)
403410
- [DAGCollection](docs/DAGCollection.md)
@@ -452,6 +459,7 @@ Class | Method | HTTP request | Description
452459
- [TaskState](docs/TaskState.md)
453460
- [TimeDelta](docs/TimeDelta.md)
454461
- [TriggerRule](docs/TriggerRule.md)
462+
- [UpdateDagRunState](docs/UpdateDagRunState.md)
455463
- [UpdateTaskInstancesState](docs/UpdateTaskInstancesState.md)
456464
- [User](docs/User.md)
457465
- [UserAllOf](docs/UserAllOf.md)

airflow_client/client/__init__.py

Lines changed: 2 additions & 2 deletions
Large diffs are not rendered by default.

airflow_client/client/api/config_api.py

Lines changed: 64 additions & 65 deletions
Large diffs are not rendered by default.

airflow_client/client/api/connection_api.py

Lines changed: 463 additions & 353 deletions
Large diffs are not rendered by default.

airflow_client/client/api/dag_api.py

Lines changed: 765 additions & 651 deletions
Large diffs are not rendered by default.

airflow_client/client/api/dag_run_api.py

Lines changed: 504 additions & 373 deletions
Large diffs are not rendered by default.

airflow_client/client/api/event_log_api.py

Lines changed: 135 additions & 138 deletions
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)