Skip to content

Commit 3a3aa79

Browse files
authored
fix: Change Log Severities for Terminated Streams (#1433)
1 parent b0f6f49 commit 3a3aa79

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1281,7 +1281,7 @@ def _on_fatal_exception(self, exception: BaseException) -> None:
12811281
Called whenever `self.consumer` receives a non-retryable exception.
12821282
We close the manager on such non-retryable cases.
12831283
"""
1284-
_LOGGER.exception(
1284+
_LOGGER.info(
12851285
"Streaming pull terminating after receiving non-recoverable error: %s",
12861286
exception,
12871287
)
@@ -1326,7 +1326,7 @@ def _should_terminate(self, exception: BaseException) -> bool:
13261326
is_api_error = isinstance(exception, exceptions.GoogleAPICallError)
13271327
# Terminate any non-API errors, or non-retryable errors (permission denied, unauthorized, etc.)
13281328
if not is_api_error or isinstance(exception, _TERMINATING_STREAM_ERRORS):
1329-
_LOGGER.error("Observed terminating stream error %s", exception)
1329+
_LOGGER.debug("Observed terminating stream error %s", exception)
13301330
return True
13311331
_LOGGER.debug("Observed non-terminating stream error %s", exception)
13321332
return False

0 commit comments

Comments
 (0)