subhramit commented on code in PR #73403:
URL: https://github.com/apache/airflow/pull/73403#discussion_r4057044400
##########
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_assets.py:
##########
@@ -108,3 +113,27 @@ def test_asset_uri_not_found(self, client):
"reason": "not_found",
}
}
+
+
[email protected]("reconfigure_async_db_engine")
+class TestGetAssetAsyncQueries:
Review Comment:
Have added it here inspired by https://github.com/apache/airflow/pull/73407
only for the simpler routes that do direct `AsyncSession` reads in the handler
itself, where an awaited-call assertion gives clear extra signal with little
test noise. This pattern of test is not needed for every migrated endpoint.
For example, `GET /execution/assets/by-name`, `GET
/execution/assets/by-uri`, `GET /execution/dag-runs/count`, and `GET
/execution/variables/keys` map very directly to `await session.scalar(...)` /
`await session.scalars(...)`, so mocking those calls is straightforward.
For endpoints like `previos-successful-dagrun`, `previous task instance`,
or `breadcrumbs`, the existing DB-backed contract tests already cover behavior
well, so additional async-session mocking would IMO add a lot more coupling
than value.
--
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]
