fix: change info logs to debug

google/cloud/pubsub_v1/subscriber/_protocol/heartbeater.py

@@ -48,7 +48,7 @@ def heartbeat(self) -> None:
                 _LOGGER.debug("Sent heartbeat.")
             self._stop_event.wait(timeout=self._period)
 
-        _LOGGER.info("%s exiting.", _HEARTBEAT_WORKER_NAME)
+        _LOGGER.debug("%s exiting.", _HEARTBEAT_WORKER_NAME)
 
     def start(self) -> None:
         with self._operational_lock:

google/cloud/pubsub_v1/subscriber/_protocol/leaser.py

@@ -212,7 +212,7 @@ def maintain_leases(self) -> None:
             _LOGGER.debug("Snoozing lease management for %f seconds.", snooze)
             self._stop_event.wait(timeout=snooze)
 
-        _LOGGER.info("%s exiting.", _LEASE_WORKER_NAME)
+        _LOGGER.debug("%s exiting.", _LEASE_WORKER_NAME)
 
     def start(self) -> None:
         with self._operational_lock:

google/cloud/pubsub_v1/subscriber/_protocol/streaming_pull_manager.py

@@ -743,7 +743,7 @@ def heartbeat(self) -> bool:
                 request = gapic_types.StreamingPullRequest(
                     stream_ack_deadline_seconds=self.ack_deadline
                 )
-                _LOGGER.info(
+                _LOGGER.debug(
                     "Sending new ack_deadline of %d seconds.", self.ack_deadline
                 )
             else:
@@ -1081,9 +1081,9 @@ def _should_recover(self, exception: BaseException) -> bool:
         # If this is in the list of idempotent exceptions, then we want to
         # recover.
         if isinstance(exception, _RETRYABLE_STREAM_ERRORS):
-            _LOGGER.info("Observed recoverable stream error %s", exception)
+            _LOGGER.debug("Observed recoverable stream error %s", exception)
             return True
-        _LOGGER.info("Observed non-recoverable stream error %s", exception)
+        _LOGGER.debug("Observed non-recoverable stream error %s", exception)
         return False
 
     def _should_terminate(self, exception: BaseException) -> bool:
@@ -1101,9 +1101,9 @@ def _should_terminate(self, exception: BaseException) -> bool:
         """
         exception = _wrap_as_exception(exception)
         if isinstance(exception, _TERMINATING_STREAM_ERRORS):
-            _LOGGER.info("Observed terminating stream error %s", exception)
+            _LOGGER.debug("Observed terminating stream error %s", exception)
             return True
-        _LOGGER.info("Observed non-terminating stream error %s", exception)
+        _LOGGER.debug("Observed non-terminating stream error %s", exception)
         return False
 
     def _on_rpc_done(self, future: Any) -> None:
@@ -1117,7 +1117,7 @@ def _on_rpc_done(self, future: Any) -> None:
         with shutting everything down. This is to prevent blocking in the
         background consumer and preventing it from being ``joined()``.
         """
-        _LOGGER.info("RPC termination has signaled streaming pull manager shutdown.")
+        _LOGGER.debug("RPC termination has signaled streaming pull manager shutdown.")
         error = _wrap_as_exception(future)
         thread = threading.Thread(
             name=_RPC_ERROR_THREAD_NAME, target=self._shutdown, kwargs={"reason": error}

samples/snippets/subscriber.py

@@ -771,14 +771,14 @@ def synchronous_pull_with_lease_management(
                         "ack_deadline_seconds": 15,
                     }
                 )
-                logger.info(f"Reset ack deadline for {msg_data}.")
+                logger.debug(f"Reset ack deadline for {msg_data}.")
 
             # If the process is complete, acknowledge the message.
             else:
                 subscriber.acknowledge(
                     request={"subscription": subscription_path, "ack_ids": [ack_id]}
                 )
-                logger.info(f"Acknowledged {msg_data}.")
+                logger.debug(f"Acknowledged {msg_data}.")
                 processes.pop(process)
     print(
         f"Received and acknowledged {len(response.received_messages)} messages from {subscription_path}."

tests/unit/pubsub_v1/subscriber/test_leaser.py

@@ -89,7 +89,7 @@ def create_manager(flow_control=types.FlowControl()):
 
 
 def test_maintain_leases_inactive_manager(caplog):
-    caplog.set_level(logging.INFO)
+    caplog.set_level(logging.DEBUG)
     manager = create_manager()
     manager.is_active = False
 
@@ -107,7 +107,7 @@ def test_maintain_leases_inactive_manager(caplog):
 
 
 def test_maintain_leases_stopped(caplog):
-    caplog.set_level(logging.INFO)
+    caplog.set_level(logging.DEBUG)
     manager = create_manager()
 
     leaser_ = leaser.Leaser(manager)

tests/unit/pubsub_v1/subscriber/test_streaming_pull_manager.py

@@ -1036,7 +1036,7 @@ def test_heartbeat_inactive():
 
 
 def test_heartbeat_stream_ack_deadline_seconds(caplog):
-    caplog.set_level(logging.INFO)
+    caplog.set_level(logging.DEBUG)
     manager = make_manager()
     manager._rpc = mock.create_autospec(bidi.BidiRpc, instance=True)
     manager._rpc.is_active = True