Skip to content

Commit bf15172

Browse files
authored
chore(pubsub): refactor fake leaser test helper (#9632)
1 parent 6a46ac2 commit bf15172

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

pubsub/tests/unit/pubsub_v1/subscriber/test_streaming_pull_manager.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -117,20 +117,20 @@ def make_manager(**kwargs):
117117
)
118118

119119

120-
def fake_leaser_add(leaser, init_msg_count=0, init_bytes=0):
120+
def fake_leaser_add(leaser, init_msg_count=0, assumed_msg_size=10):
121121
"""Add a simplified fake add() method to a leaser instance.
122122
123123
The fake add() method actually increases the leaser's internal message count
124-
by one for each message, and the total bytes by 10 for each message (hardcoded,
125-
regardless of the actual message size).
124+
by one for each message, and the total bytes by ``assumed_msg_size`` for
125+
each message (regardless of the actual message size).
126126
"""
127127

128128
def fake_add(self, items):
129129
self.message_count += len(items)
130-
self.bytes += len(items) * 10
130+
self.bytes += len(items) * assumed_msg_size
131131

132132
leaser.message_count = init_msg_count
133-
leaser.bytes = init_bytes
133+
leaser.bytes = init_msg_count * assumed_msg_size
134134
leaser.add = stdlib_types.MethodType(fake_add, leaser)
135135

136136

@@ -256,7 +256,7 @@ def test__maybe_release_messages_below_overload():
256256

257257
# init leaser message count to 8 to leave room for 2 more messages
258258
_leaser = manager._leaser = mock.create_autospec(leaser.Leaser)
259-
fake_leaser_add(_leaser, init_msg_count=8, init_bytes=200)
259+
fake_leaser_add(_leaser, init_msg_count=8, assumed_msg_size=25)
260260
_leaser.add = mock.Mock(wraps=_leaser.add) # to spy on calls
261261

262262
messages = [
@@ -621,7 +621,7 @@ def test__on_response_no_leaser_overload():
621621
)
622622

623623
# adjust message bookkeeping in leaser
624-
fake_leaser_add(leaser, init_msg_count=0, init_bytes=0)
624+
fake_leaser_add(leaser, init_msg_count=0, assumed_msg_size=42)
625625

626626
# Actually run the method and prove that modack and schedule
627627
# are called in the expected way.
@@ -662,7 +662,7 @@ def test__on_response_with_leaser_overload():
662662

663663
# Adjust message bookkeeping in leaser. Pick 999 messages, which is just below
664664
# the default FlowControl.max_messages limit.
665-
fake_leaser_add(leaser, init_msg_count=999, init_bytes=9900)
665+
fake_leaser_add(leaser, init_msg_count=999, assumed_msg_size=10)
666666

667667
# Actually run the method and prove that modack and schedule
668668
# are called in the expected way.

0 commit comments

Comments
 (0)