Skip to content

Commit

Permalink
Update clickhouse.py
Browse files Browse the repository at this point in the history
  • Loading branch information
amolsr authored May 30, 2024
1 parent 85a60cf commit f40ec4f
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/airflow_clickhouse_plugin/hooks/clickhouse.py
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ def execute(

def get_pandas_df(
self, sql: str, parameters: t.Union[None, dict, list, tuple, t.Generator] = None
) -> Any:
) -> t.Any:
import pandas as pd

rows, columns_defs = self.run(sql, parameters, with_column_types=True)
Expand All @@ -104,7 +104,7 @@ def run(
parameters: t.Union[None, dict, list, tuple, t.Generator] = None,
with_column_types: bool = False,
types_check: bool = False,
) -> Any:
) -> t.Any:
if isinstance(sql, str):
sql = (sql,)
with _disconnecting(self.get_conn()) as conn:
Expand Down

0 comments on commit f40ec4f

Please sign in to comment.