subhramit commented on code in PR #71976:
URL: https://github.com/apache/airflow/pull/71976#discussion_r3889463103
##########
providers/influxdb/docs/operators/index.rst:
##########
@@ -46,3 +46,26 @@ Example usage:
:language: python
:start-after: [START howto_operator_influxdb3]
:end-before: [END howto_operator_influxdb3]
+
+Deferrable mode
+^^^^^^^^^^^^^^^
+
+Set ``deferrable=True`` to release the worker slot while the query runs. The
task is resumed by the
+:class:`~airflow.providers.influxdb.triggers.influxdb3.InfluxDB3QueryTrigger`
once results are ready.
+
+.. exampleinclude:: /../../influxdb/tests/system/influxdb/example_influxdb3.py
+ :language: python
+ :start-after: [START howto_operator_influxdb3_deferrable]
+ :end-before: [END howto_operator_influxdb3_deferrable]
+
+.. note::
+
+ This implementation follows the upstream ``influxdb3-python`` client,
which documents querying
+ through the `Flight client
<https://influxdb3-python.readthedocs.io/en/latest/>`__ and exposes
+ `query_async()
<https://influxdb3-python.readthedocs.io/en/latest/api_reference/>`__ as a
+ single async query call. The trigger therefore awaits one query call
instead of polling at an
+ interval, and there is no ``poll_interval`` parameter.
Review Comment:
Fair, removed
--
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]
