Skip to content

Commit

Permalink
update predicate class name
Browse files Browse the repository at this point in the history
  • Loading branch information
mikealfare committed Nov 20, 2024
1 parent 02385bb commit 51cc87f
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dbt/adapters/bigquery/retry.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,15 +56,15 @@ def create_reopen_with_deadline(self, connection: Connection) -> Retry:
This strategy mimics what was accomplished with _retry_and_handle
"""
return Retry(
predicate=_BufferedPredicate(self._retries),
predicate=_DeferredException(self._retries),
initial=_DEFAULT_INITIAL_DELAY,
maximum=_DEFAULT_MAXIMUM_DELAY,
deadline=self._job_deadline,
on_error=_create_reopen_on_error(connection),
)


class _BufferedPredicate:
class _DeferredException:
"""
Count ALL errors, not just retryable errors, up to a threshold.
Raise the next error, regardless of whether it is retryable.
Expand Down

0 comments on commit 51cc87f

Please sign in to comment.