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

Commit 0ae0340

Browse files
committed
Update test_streaming_pull_manager.py
1 parent f1f705d commit 0ae0340

1 file changed

Lines changed: 7 additions & 2 deletions

File tree

tests/unit/pubsub_v1/subscriber/test_streaming_pull_manager.py

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2270,7 +2270,12 @@ def test__should_recover_false():
22702270
def test__should_terminate_true():
22712271
manager = make_manager()
22722272

2273-
for exc in [exceptions.PermissionDenied(""), TypeError(), ValueError()]:
2273+
for exc in [
2274+
exceptions.Cancelled(""),
2275+
exceptions.PermissionDenied(""),
2276+
TypeError(),
2277+
ValueError(),
2278+
]:
22742279
assert manager._should_terminate(exc)
22752280

22762281

@@ -2280,7 +2285,7 @@ def test__should_terminate_false():
22802285
for exc in [
22812286
exceptions.ResourceExhausted(""),
22822287
exceptions.ServiceUnavailable(""),
2283-
exceptions.Cancelled(""),
2288+
exceptions.DeadlineExceeded(""),
22842289
]:
22852290
assert not manager._should_terminate(exc)
22862291

0 commit comments

Comments
 (0)