subhramit commented on PR #71976: URL: https://github.com/apache/airflow/pull/71976#issuecomment-5444655844
> Can you please confirm if this was tested against a real influx environment? Yeah. Can give an MWE as well. Setup was `influxdb:3-core` with a file object store, two rows written to a `home` table over the v3 line-protocol endpoint, read back through the influxdb3 CLI: <img width="867" height="182" alt="image" src="https://github.com/user-attachments/assets/f466bb9b-6765-454f-82b1-4401401f29ef"; /> The async client on its own against the same server, to isolate it from Airflow: ```python c = InfluxDBClient3(host="http://localhost:8181";, token=TOKEN, database="airflow_demo") print(asyncio.run(c.query_async("SELECT * FROM home")).to_pydict()) ``` <img width="1073" height="104" alt="image" src="https://github.com/user-attachments/assets/8783e80a-35d8-4901-b074-dd542145c6ac"; /> Then through the operator - the deferrable task alongside the sync one running the same query, so the two paths could be compared: ```python blocking = InfluxDB3Operator(task_id="query_blocking", sql=SQL, influxdb3_conn_id=CONN) deferred = InfluxDB3Operator(task_id="query_deferred", sql=SQL, influxdb3_conn_id=CONN, deferrable=True) blocking >> deferred ``` `query_deferred` deferred to the triggerer, the trigger fired a success event, and the task resumed from `QUEUED` with the same two records the sync task returned: <img width="2056" height="685" alt="image" src="https://github.com/user-attachments/assets/06b41599-8b6c-4fd2-852a-4dd1aa1d6c2c"; /> -- 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]
