Leondon9 opened a new pull request, #67941: URL: https://github.com/apache/airflow/pull/67941
Add a small server-side partition lookup for asset events and a standard provider sensor that can wait for a specific asset partition from a time-scheduled DAG. What changed: - Added partition_key exact filtering to Execution API asset event lookups by asset and by asset alias. - Threaded partition_key through the Task SDK client, comms models, task supervisor, triggerer supervisor, and inlet event accessor. - Added AssetPartitionSensor and AssetPartitionTrigger in the standard provider. - Added focused tests for the API filter, SDK forwarding path, sensor, and trigger behavior. This is intended as a narrow draft for the idea in #67375. It deliberately avoids broader pattern/regex filters, Core API expansion, DB migrations/indexes, UI changes, and generated OpenAPI churn. It overlaps with part of #64610 only in the exact partition lookup surface; if #64610 lands first, this branch should be rebased and the lookup commit can likely be dropped or reduced. Validation: - prek run ruff-format --files ... - prek run ruff --files ... Pytest was attempted with Breeze, but the local test bootstrap failed before collecting/running the changed tests due provider discovery/import setup issues (airflow.providers.akeyless) and task_sdk import setup in the container. related: #67375 --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes — Codex (GPT-5) Generated-by: Codex (GPT-5) following https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions -- 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]
