subhramit commented on code in PR #71976:
URL: https://github.com/apache/airflow/pull/71976#discussion_r3889388773
##########
providers/influxdb/src/airflow/providers/influxdb/operators/influxdb3.py:
##########
@@ -23,13 +23,21 @@
from collections.abc import Sequence
from typing import TYPE_CHECKING, Any
-from airflow.providers.common.compat.sdk import BaseOperator
+from airflow.providers.common.compat.sdk import BaseOperator, conf
from airflow.providers.influxdb.hooks.influxdb3 import InfluxDB3Hook
+from airflow.providers.influxdb.triggers.influxdb3 import InfluxDB3QueryTrigger
if TYPE_CHECKING:
+ import pandas as pd
+
from airflow.sdk.definitions.context import Context
+def _convert_dataframe_to_records(dataframe: pd.DataFrame) -> list[dict[str,
Any]]:
Review Comment:
@eladkal wanted this to be private in
https://github.com/apache/airflow/pull/71976#discussion_r3871657602, so I
wasn't sure what to do as the only other option was to create a private helper
utils file for this tiny method.
Maybe when I work on the sensor I'll need it anyway so I'll move this to a
file now.
--
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]
