🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

Author: gcf-owl-bot[bot]

tests/unit/pubsub_v1/conftest.py

@@ -45,6 +45,7 @@ def span_exporter():
     provider.add_span_processor(processor)
     yield exporter
 
+
 @pytest.fixture()
 def modify_google_logger_propagation():
     """

tests/unit/pubsub_v1/subscriber/test_heartbeater.py

@@ -27,7 +27,10 @@
 
 import pytest
 
-def test_heartbeat_inactive_manager_active_rpc(caplog, modify_google_logger_propagation):
+
+def test_heartbeat_inactive_manager_active_rpc(
+    caplog, modify_google_logger_propagation
+):
     caplog.set_level(logging.DEBUG)
 
     manager = mock.create_autospec(
@@ -45,7 +48,10 @@ def test_heartbeat_inactive_manager_active_rpc(caplog, modify_google_logger_prop
     assert "exiting" in caplog.text
 
 
-def test_heartbeat_inactive_manager_inactive_rpc(caplog, modify_google_logger_propagation,):
+def test_heartbeat_inactive_manager_inactive_rpc(
+    caplog,
+    modify_google_logger_propagation,
+):
     caplog.set_level(logging.DEBUG)
 
     manager = mock.create_autospec(

tests/unit/pubsub_v1/subscriber/test_streaming_pull_manager.py

@@ -603,7 +603,9 @@ def test__maybe_release_messages_below_overload():
         assert call_args[1].ack_id in ("ack_foo", "ack_bar")
 
 
-def test__maybe_release_messages_negative_on_hold_bytes_warning(caplog, modify_google_logger_propagation):
+def test__maybe_release_messages_negative_on_hold_bytes_warning(
+    caplog, modify_google_logger_propagation
+):
     manager = make_manager(
         flow_control=types.FlowControl(max_messages=10, max_bytes=1000)
     )
@@ -978,7 +980,9 @@ def test_send_unary_modack_api_call_error(caplog, modify_google_logger_propagati
     assert "The front fell off" in caplog.text
 
 
-def test_send_unary_ack_retry_error_exactly_once_disabled_no_futures(caplog, modify_google_logger_propagation):
+def test_send_unary_ack_retry_error_exactly_once_disabled_no_futures(
+    caplog, modify_google_logger_propagation
+):
     caplog.set_level(logging.DEBUG)
 
     manager, _, _, _, _, _ = make_running_manager()
@@ -1014,7 +1018,9 @@ def test_send_unary_ack_retry_error_exactly_once_disabled_no_futures(caplog, mod
     assert "signaled streaming pull manager shutdown" in caplog.text
 
 
-def test_send_unary_ack_retry_error_exactly_once_disabled_with_futures(caplog, modify_google_logger_propagation):
+def test_send_unary_ack_retry_error_exactly_once_disabled_with_futures(
+    caplog, modify_google_logger_propagation
+):
     caplog.set_level(logging.DEBUG)
 
     manager, _, _, _, _, _ = make_running_manager()
@@ -1054,7 +1060,9 @@ def test_send_unary_ack_retry_error_exactly_once_disabled_with_futures(caplog, m
     assert future2.result() == subscriber_exceptions.AcknowledgeStatus.SUCCESS
 
 
-def test_send_unary_ack_retry_error_exactly_once_enabled_no_futures(caplog, modify_google_logger_propagation):
+def test_send_unary_ack_retry_error_exactly_once_enabled_no_futures(
+    caplog, modify_google_logger_propagation
+):
     caplog.set_level(logging.DEBUG)
 
     manager, _, _, _, _, _ = make_running_manager()
@@ -1090,7 +1098,9 @@ def test_send_unary_ack_retry_error_exactly_once_enabled_no_futures(caplog, modi
     assert "signaled streaming pull manager shutdown" in caplog.text
 
 
-def test_send_unary_ack_retry_error_exactly_once_enabled_with_futures(caplog, modify_google_logger_propagation):
+def test_send_unary_ack_retry_error_exactly_once_enabled_with_futures(
+    caplog, modify_google_logger_propagation
+):
     caplog.set_level(logging.DEBUG)
 
     manager, _, _, _, _, _ = make_running_manager()
@@ -1136,7 +1146,9 @@ def test_send_unary_ack_retry_error_exactly_once_enabled_with_futures(caplog, mo
     )
 
 
-def test_send_unary_modack_retry_error_exactly_once_disabled_no_future(caplog, modify_google_logger_propagation):
+def test_send_unary_modack_retry_error_exactly_once_disabled_no_future(
+    caplog, modify_google_logger_propagation
+):
     caplog.set_level(logging.DEBUG)
 
     manager, _, _, _, _, _ = make_running_manager()
@@ -1162,8 +1174,7 @@ def test_send_unary_modack_retry_error_exactly_once_disabled_no_future(caplog, m
 
 
 def test_send_unary_modack_retry_error_exactly_once_disabled_with_futures(
-    caplog,
-    modify_google_logger_propagation
+    caplog, modify_google_logger_propagation
 ):
     caplog.set_level(logging.DEBUG)
 
@@ -1192,8 +1203,7 @@ def test_send_unary_modack_retry_error_exactly_once_disabled_with_futures(
 
 
 def test_send_unary_modack_retry_error_exactly_once_enabled_no_futures(
-    caplog,
-    modify_google_logger_propagation
+    caplog, modify_google_logger_propagation
 ):
     caplog.set_level(logging.DEBUG)
 
@@ -1220,8 +1230,7 @@ def test_send_unary_modack_retry_error_exactly_once_enabled_no_futures(
 
 
 def test_send_unary_modack_retry_error_exactly_once_enabled_with_futures(
-    caplog,
-    modify_google_logger_propagation
+    caplog, modify_google_logger_propagation
 ):
     caplog.set_level(logging.DEBUG)
 
@@ -1274,7 +1283,9 @@ def test_heartbeat_inactive():
     assert not result
 
 
-def test_heartbeat_stream_ack_deadline_seconds(caplog, modify_google_logger_propagation):
+def test_heartbeat_stream_ack_deadline_seconds(
+    caplog, modify_google_logger_propagation
+):
     caplog.set_level(logging.DEBUG)
     manager = make_manager()
     manager._rpc = mock.create_autospec(bidi.BidiRpc, instance=True)
@@ -2090,7 +2101,10 @@ def test__on_response_disable_exactly_once():
     assert manager._stream_ack_deadline == 60
 
 
-def test__on_response_exactly_once_immediate_modacks_fail(caplog, modify_google_logger_propagation,):
+def test__on_response_exactly_once_immediate_modacks_fail(
+    caplog,
+    modify_google_logger_propagation,
+):
     manager, _, dispatcher, leaser, _, scheduler = make_running_manager()
     manager._callback = mock.sentinel.callback
 
@@ -2162,7 +2176,9 @@ def complete_futures_with_error(*args, **kwargs):
     assert manager.load == 0.001
 
 
-def test__on_response_exactly_once_immediate_modacks_fail_non_invalid(caplog, modify_google_logger_propagation):
+def test__on_response_exactly_once_immediate_modacks_fail_non_invalid(
+    caplog, modify_google_logger_propagation
+):
     manager, _, dispatcher, leaser, _, scheduler = make_running_manager()
     manager._callback = mock.sentinel.callback