Update Python Client to 3.3.0rc1

Author: vatsrahul1001

CHANGELOG.md

@@ -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:

README.md

@@ -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' \
@@ -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

airflow_client/client/__init__.py

@@ -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
@@ -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