amoghrajesh opened a new pull request, #58028:
URL: https://github.com/apache/airflow/pull/58028
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
distributed with this work for additional information
regarding copyright ownership. The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on an
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->
<!--
Thank you for contributing! Please make sure that your code changes
are covered with tests. And in case of new features or big changes
remember to adjust the documentation.
Feel free to ping committers for the review!
In case of an existing issue, reference it using one of the following:
closes: #ISSUE
related: #ISSUE
How to write a good git commit message:
http://chris.beams.io/posts/git-commit/
-->
Built on top: https://github.com/apache/airflow/pull/58027, only changes to
task-sdk-tests/tests/task_sdk_tests/test_asset_event_operations.py are relevant.
```python
(airflow) ➜ task-sdk-tests
git:(extend-integration-tests-asset-event-operations) ✗ uv run pytest
tests/task_sdk_tests/test_asset_event_operations.py -s
Installing apache-airflow-task-sdk==1.1.0 via pytest_sessionstart...
Installing from: /Users/amoghdesai/Documents/OSS/repos/airflow/task-sdk
Installing to current UV environment...
Current Python:
/Users/amoghdesai/Documents/OSS/repos/airflow/.venv/bin/python3
Running command: uv pip install
/Users/amoghdesai/Documents/OSS/repos/airflow/task-sdk
Using Python 3.13.3 environment at:
/Users/amoghdesai/Documents/OSS/repos/airflow/.venv
Resolved 125 packages in 270ms
Built apache-airflow-task-sdk @
file:///Users/amoghdesai/Documents/OSS/repos/airflow/task-sdk
Prepared 1 package in 217ms
Uninstalled 1 package in 1ms
Installed 1 package in 1ms
~ apache-airflow-task-sdk==1.2.0 (from
file:///Users/amoghdesai/Documents/OSS/repos/airflow/task-sdk)
Task SDK installed successfully to UV environment via pytest_sessionstart!
Verifying task Task installation via pytest_sessionstart...
✅ Task SDK import successful via pytest_sessionstart
================================================= test session starts
=================================================
platform darwin -- Python 3.13.3, pytest-8.4.1, pluggy-1.6.0 --
/Users/amoghdesai/Documents/OSS/repos/airflow/.venv/bin/python3
cachedir: .pytest_cache
rootdir: /Users/amoghdesai/Documents/OSS/repos/airflow/task-sdk-tests
configfile: pyproject.toml
plugins: unordered-0.7.0, instafail-0.5.0, timeouts-1.2.1, asyncio-1.1.0,
xdist-3.8.0, custom-exit-code-0.3.0, anyio-4.10.0, icdiff-0.9,
rerunfailures-15.1, cov-6.2.1, kgb-7.2, mock-3.14.1, time-machine-2.17.0,
requests-mock-1.12.1
asyncio: mode=Mode.STRICT, asyncio_default_fixture_loop_scope=None,
asyncio_default_test_loop_scope=function
setup timeout: 0.0s, execution timeout: 0.0s, teardown timeout: 0.0s
collected 2 items
tests/task_sdk_tests/test_asset_event_operations.py::test_asset_event_get
Starting docker-compose for session...
WARN[0000] The "AIRFLOW_UID" variable is not set. Defaulting to a blank
string.
WARN[0000] The "AIRFLOW_UID" variable is not set. Defaulting to a blank
string.
[+] Running 6/6
✔ Network airflow-task-sdk-test0_default Created
0.0s
✔ Container airflow-task-sdk-test0-postgres-1 Hea...
26.3s
✔ Container airflow-task-sdk-test0-airflow-init-1 Exited
26.3s
✔ Container airflow-task-sdk-test0-airflow-dag-processor-1 Healthy
26.3s
✔ Container airflow-task-sdk-test0-airflow-scheduler-1 Healthy
57.8s
✔ Container airflow-task-sdk-test0-airflow-apiserver-1 Healthy
41.3s
Docker compose started successfully!
✅ Got auth token
Checking asset_producer_dag status...
Unpausing asset_producer_dag...
asset_producer_dag unpaused
Triggering asset_producer_dag...
asset_producer_dag triggered: manual__2025-11-07T08:26:21.001915+00:00
Waiting for asset_producer_dag to complete...
Waiting for asset_producer_dag to complete (attempt 1/60, state: queued)
Waiting for asset_producer_dag to complete (attempt 2/60, state: running)
asset_producer_dag completed successfully!
Getting task instance ID from asset_producer_dag...
Found task instance ID: 019a5d6c-77d6-73a8-b991-f420a26a310c
Getting asset events by name...
======================= Asset Event Get Response =======================
Response Type: AssetEventsResponse
Number of Events: 1
First Event ID: 1
First Event Asset Name: test_asset
First Event Asset URI: test://asset1/
First Event Timestamp: 2025-11-07 08:26:23.462290+00:00
========================================================================
✅ Asset event get test passed!
PASSED
tests/task_sdk_tests/test_asset_event_operations.py::test_asset_event_get_not_found
Getting asset events for non-existent asset...
================= Asset Event Get (Not Found) Response =================
Response Type: AssetEventsResponse
Number of Events: 0
========================================================================
✅ Asset event get (not found) test passed!
PASSEDCleaning up docker-compose...
Docker compose cleaned up
============================================ 2 passed in 82.69s (0:01:22)
=============================================
```
<!-- Please keep an empty line above the dashes. -->
---
**^ Add meaningful description above**
Read the **[Pull Request
Guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#pull-request-guidelines)**
for more information.
In case of fundamental code changes, an Airflow Improvement Proposal
([AIP](https://cwiki.apache.org/confluence/display/AIRFLOW/Airflow+Improvement+Proposals))
is needed.
In case of a new dependency, check compliance with the [ASF 3rd Party
License Policy](https://www.apache.org/legal/resolved.html#category-x).
In case of backwards incompatible changes please leave a note in a
newsfragment file, named `{pr_number}.significant.rst` or
`{issue_number}.significant.rst`, in
[airflow-core/newsfragments](https://github.com/apache/airflow/tree/main/airflow-core/newsfragments).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
