Skip to content

Commit dcae615

Browse files
committed
fix mypy
1 parent 9dd03ed commit dcae615

2 files changed

Lines changed: 10 additions & 8 deletions

File tree

packages/bigframes/bigframes/pandas/io/api.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,7 @@ def _try_read_gbq_colab_sessionless_dry_run(
300300
def _read_gbq_colab( # type: ignore[overload-overlap]
301301
query_or_table: str,
302302
*,
303-
callback: Optional[Callable[[bigframes.core.events.Event], None]] = ...,
303+
callback: Optional[Callable[[bigframes.core.events.EventEnvelope], None]] = ...,
304304
pyformat_args: Optional[Dict[str, Any]] = ...,
305305
dry_run: Literal[False] = ...,
306306
) -> bigframes.dataframe.DataFrame: ...
@@ -310,7 +310,7 @@ def _read_gbq_colab( # type: ignore[overload-overlap]
310310
def _read_gbq_colab(
311311
query_or_table: str,
312312
*,
313-
callback: Optional[Callable[[bigframes.core.events.Event], None]] = ...,
313+
callback: Optional[Callable[[bigframes.core.events.EventEnvelope], None]] = ...,
314314
pyformat_args: Optional[Dict[str, Any]] = ...,
315315
dry_run: Literal[True] = ...,
316316
) -> pandas.Series: ...
@@ -319,7 +319,7 @@ def _read_gbq_colab(
319319
def _read_gbq_colab(
320320
query_or_table: str,
321321
*,
322-
callback: Optional[Callable[[bigframes.core.events.Event], None]] = None,
322+
callback: Optional[Callable[[bigframes.core.events.EventEnvelope], None]] = None,
323323
pyformat_args: Optional[Dict[str, Any]] = None,
324324
dry_run: bool = False,
325325
) -> bigframes.dataframe.DataFrame | pandas.Series:
@@ -331,7 +331,7 @@ def _read_gbq_colab(
331331
Args:
332332
query_or_table (str):
333333
SQL query or table ID (table ID not yet supported).
334-
callback (Optional[Callable[[bigframes.core.events.Event], None]]):
334+
callback (Optional[Callable[[bigframes.core.events.EventEnvelope], None]]):
335335
Callback to receive query execution events.
336336
pyformat_args (Optional[Dict[str, Any]]):
337337
Parameters to format into the query string.

packages/bigframes/bigframes/session/__init__.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -667,7 +667,7 @@ def _read_gbq_colab(
667667
self,
668668
query: str,
669669
*,
670-
callback: Optional[Callable[[bigframes.core.events.Event], None]] = ...,
670+
callback: Optional[Callable[[bigframes.core.events.EventEnvelope], None]] = ...,
671671
pyformat_args: Optional[Dict[str, Any]] = None,
672672
dry_run: Literal[False] = ...,
673673
) -> dataframe.DataFrame: ...
@@ -677,7 +677,7 @@ def _read_gbq_colab(
677677
self,
678678
query: str,
679679
*,
680-
callback: Optional[Callable[[bigframes.core.events.Event], None]] = ...,
680+
callback: Optional[Callable[[bigframes.core.events.EventEnvelope], None]] = ...,
681681
pyformat_args: Optional[Dict[str, Any]] = None,
682682
dry_run: Literal[True] = ...,
683683
) -> pandas.Series: ...
@@ -687,7 +687,9 @@ def _read_gbq_colab(
687687
self,
688688
query: str,
689689
*,
690-
callback: Optional[Callable[[bigframes.core.events.Event], None]] = None,
690+
callback: Optional[
691+
Callable[[bigframes.core.events.EventEnvelope], None]
692+
] = None,
691693
pyformat_args: Optional[Dict[str, Any]] = None,
692694
dry_run: bool = False,
693695
) -> Union[dataframe.DataFrame, pandas.Series]:
@@ -700,7 +702,7 @@ def _read_gbq_colab(
700702
query (str):
701703
A SQL query string to execute. Results (if any) are turned into
702704
a DataFrame.
703-
callback (Optional[Callable[[bigframes.core.events.Event], None]]):
705+
callback (Optional[Callable[[bigframes.core.events.EventEnvelope], None]]):
704706
Callback to receive query execution events.
705707
pyformat_args (dict):
706708
A dictionary of potential variables to replace in ``query``.

0 commit comments

Comments
 (0)