Skip to content

Update Python Client to 3.3.0 #157

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
vatsrahul1001 merged 1 commit into from
Jul 8, 2026
Merged

Update Python Client to 3.3.0 #157

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
49 changes: 49 additions & 0 deletions CHANGELOG.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,55 @@
under the License.
-->

# v3.3.0

## New Features:

- AIP-103: Add Core API endpoints for task state and asset state (#67041)
- AIP-103: Add patch task state core API and support for ``expires_at`` in set API (#67319)
- Add ``awaiting_input`` task state for Human-in-the-loop (#68028)
- Return dag-specified results in the dag run wait API (#64577)
- Add ``POST /dags/{dag_id}/clearDagRuns`` bulk endpoint (#67709)
- Add bulk delete Dag Runs (#67095)
- Add bulk update to mark Dag runs as success/failed (#67948)
- Clear, mark success/failed and delete multiple task instances (#64141)
- Add partition clear support to the REST API matching the CLI (#68702)
- Propagate ``partition_date`` to consumers of partitioned assets (#67285)
- Add consumer-team asset filtering API endpoint support (#68034)
- Add Dag runs filters for Consuming Asset (#63624)
- Add async connection testing via workers for security isolation (#62343)
- Add ``nav_top_level`` option for plugin nav items (#67084)
- Implement patching of task group instances in the API (#62812)
- Add cursor-based pagination for the ``get_dag_runs`` endpoint (#65604)
- Add cursor-based pagination for the ``get_task_instances`` endpoint (#64845)
- Support ordering ``XCom`` entries in the REST API (#65418)
- Enable queueing up new tasks (#63484)
- Add the "is backfillable" property for Dags (#64644)
- Add ``DagRunType`` for operator (#63733)
- Pass ``try_number`` to the extra links API (#65661)
- Add ``rerun_with_latest_version`` config hierarchy for clear/rerun behavior (#63884)

## Improvements:

- Record writer info for every asset-store write for better cross-linkage (#67902)
- Apply note when clearing a Dag Run / task instances (#67639)
- Update search parameters to better leverage DB indexes (#64963)
- Filter task instances by rendered map index (#66008)
- Handle undecryptable Variable values gracefully in the Stable REST API (#65452)
- Surface import errors on deactivated Dags (#65687)
- Align Dag capitalization from "DAG" to "Dag" in the API (#66211, #66099, #66112)

## Bug Fixes:

- Stop exposing trigger kwargs in the REST API response (#67868)
- Fix Dag run partition-key filter breaking on composite keys with ``|`` (#68459)
- Fix sort order for mapped task instances (#67551)
- Fix using the Dag form when materializing an asset (#64211)
- Fix ``GET /auth/login`` missing 400 in the OpenAPI spec (#67571)
- Fix ``GET /pools`` list endpoint incorrectly documenting 404 in the OpenAPI spec (#67570)
- Fix backfill params not overriding existing Dag run conf (#64939)
- Fix ``PATCH /dags`` pagination bug and document wildcard ``dag_id_pattern`` (#63665)

# v3.2.2

## Improvements:
Expand Down
4 changes: 2 additions & 2 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ the Apache Airflow API.
Note that you will need to pass authentication credentials. If your Airflow deployment supports
**Bearer token authentication**, you can use the following example:

For example, here is how to pause a DAG with `curl`, using a Bearer token:
For example, here is how to pause a Dag with `curl`, using a Bearer token:

```bash
curl -X PATCH 'https://example.com/api/v2/dags/{dag_id}?update_mask=is_paused' \
Expand Down Expand Up @@ -651,7 +651,7 @@ configuration = airflow_client.client.Configuration(host="http://localhost:8080"

* Run scheduler (or dag file processor you have setup with standalone dag file processor) for few parsing
loops (you can pass --num-runs parameter to it or keep it running in the background). The script relies
on example DAGs being serialized to the DB and this only
on example Dags being serialized to the DB and this only
happens when scheduler runs with ``core/load_examples`` set to True.

* Run webserver - reachable at the host/port for the test script you want to run. Make sure it had enough
Expand Down
60 changes: 57 additions & 3 deletions airflow_client/client/__init__.py
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 2 additions & 0 deletions airflow_client/client/api/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@

# import apis into api package
from airflow_client.client.api.asset_api import AssetApi
from airflow_client.client.api.asset_state_store_api import AssetStateStoreApi
from airflow_client.client.api.backfill_api import BackfillApi
from airflow_client.client.api.config_api import ConfigApi
from airflow_client.client.api.connection_api import ConnectionApi
Expand All @@ -23,6 +24,7 @@
from airflow_client.client.api.provider_api import ProviderApi
from airflow_client.client.api.task_api import TaskApi
from airflow_client.client.api.task_instance_api import TaskInstanceApi
from airflow_client.client.api.task_state_store_api import TaskStateStoreApi
from airflow_client.client.api.variable_api import VariableApi
from airflow_client.client.api.version_api import VersionApi
from airflow_client.client.api.x_com_api import XComApi
Expand Down
Loading
Loading