subhramit opened a new pull request, #71976:
URL: https://github.com/apache/airflow/pull/71976
<!-- SPDX-License-Identifier: Apache-2.0
https://www.apache.org/licenses/LICENSE-2.0 -->
Closes https://github.com/apache/airflow/issues/67107
Add deferrable support to `InfluxDB3Operator`.
When `deferrable=True`, the operator now defers to a new
`InfluxDB3QueryTrigger` so the worker slot is released while the query runs.
The trigger awaits `InfluxDBClient3.query_async()` and resumes the task with
the same JSON-serializable record shape returned by the synchronous path.
Also update provider metadata and documentation to surface the trigger, add
a deferrable example, and bump the `influxdb3-python` minimum version to
`>=0.12.0` (the release that introduced `query_async()`).
Have added tests for the new deferrable operator path, trigger
serialization/execution, and async hook behavior.
---
##### Was generative AI tooling used to co-author this PR?
<!--
If generative AI tooling has been used in the process of authoring this PR,
please
change below checkbox to `[X]` followed by the name of the tool, uncomment
the "Generated-by".
-->
- [x] Yes (please specify the tool below)
Generated-by: GPT-5.4 following [the
guidelines](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]
