Skip to content

Commit

Permalink
Fix mypy issues for bigquery async
Browse files Browse the repository at this point in the history
  • Loading branch information
sunank200 committed Feb 28, 2022
1 parent 5000e61 commit 0f5562e
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion astronomer/providers/google/cloud/hooks/bigquery.py
Original file line number Diff line number Diff line change
Expand Up @@ -203,7 +203,7 @@ def value_check(
raise AirflowException(error_msg)

@staticmethod
def _get_numeric_matches(records: list[float], pass_value: float, tolerance: float = None):
def _get_numeric_matches(records, pass_value: float, tolerance: float = None):
"""
A helper function to match numeric pass_value, tolerance with records value
Expand Down
2 changes: 1 addition & 1 deletion astronomer/providers/google/cloud/triggers/bigquery.py
Original file line number Diff line number Diff line change
Expand Up @@ -200,7 +200,7 @@ def __init__(
second_job_id: str,
project_id: Optional[str],
table: str,
metrics_thresholds: dict[str, Any],
metrics_thresholds: Dict[str, Any],
date_filter_column: Optional[str] = "ds",
days_back: SupportsAbs[int] = -7,
ratio_formula: str = "max_over_min",
Expand Down
2 changes: 1 addition & 1 deletion astronomer/providers/google/cloud/triggers/gcs.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ def __init__(
object_name: str,
polling_period_seconds: float,
google_cloud_conn_id: str,
hook_params: dict[str, Any],
hook_params: Dict[str, Any],
):
self.bucket = bucket
self.object_name = object_name
Expand Down

0 comments on commit 0f5562e

Please sign in to comment.