Skip to content
This repository was archived by the owner on Mar 2, 2026. It is now read-only.

Commit 6694640

Browse files
1 parent 86c89bd commit 6694640

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

tests/unit/v1/test_aggregation.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -676,7 +676,9 @@ def _stream_w_exception(*_args, **_kw):
676676
query = make_query(parent)
677677
aggregation_query = make_aggregation_query(query)
678678

679-
get_response = aggregation_query.stream(transaction=transaction, **kwargs, read_time=read_time)
679+
get_response = aggregation_query.stream(
680+
transaction=transaction, **kwargs, read_time=read_time
681+
)
680682

681683
assert isinstance(get_response, stream_generator.StreamGenerator)
682684
if expect_retry:
@@ -748,7 +750,9 @@ def test_aggregation_query_stream_w_retriable_exc_w_retry():
748750

749751

750752
def test_aggregation_query_stream_w_retriable_exc_w_read_time():
751-
_aggregation_query_stream_w_retriable_exc_helper(read_time=datetime.now(tz=timezone.utc))
753+
_aggregation_query_stream_w_retriable_exc_helper(
754+
read_time=datetime.now(tz=timezone.utc)
755+
)
752756

753757

754758
def test_aggregation_query_stream_w_retriable_exc_w_transaction():

0 commit comments

Comments
 (0)