PubSub: Renaming logger -> _LOGGER since at module scope. (#4459)

Author: dhermes

google/cloud/pubsub_v1/subscriber/policy/thread.py

@@ -28,12 +28,12 @@
 from google.cloud.pubsub_v1.subscriber.message import Message
 
 
-logger = logging.getLogger(__name__)
+_LOGGER = logging.getLogger(__name__)
 
 
 def _callback_completed(future):
     """Simple callback that just logs a `Future`'s result."""
-    logger.debug('Result: %s', future.result())
+    _LOGGER.debug('Result: %s', future.result())
 
 
 class Policy(base.BasePolicy):
@@ -80,7 +80,7 @@ def __init__(self, client, subscription, flow_control=types.FlowControl(),
         )
 
         # Also maintain a request queue and an executor.
-        logger.debug('Creating callback requests thread (not starting).')
+        _LOGGER.debug('Creating callback requests thread (not starting).')
         if executor is None:
             executor = futures.ThreadPoolExecutor(max_workers=10)
         self._executor = executor
@@ -122,7 +122,7 @@ def open(self, callback):
         self._future = Future(policy=self)
 
         # Start the thread to pass the requests.
-        logger.debug('Starting callback requests worker.')
+        _LOGGER.debug('Starting callback requests worker.')
         self._callback = callback
         self._consumer.helper_threads.start(
             'callback requests worker',
@@ -135,7 +135,7 @@ def open(self, callback):
 
         # Spawn a helper thread that maintains all of the leases for
         # this policy.
-        logger.debug('Spawning lease maintenance worker.')
+        _LOGGER.debug('Spawning lease maintenance worker.')
         self._leaser = threading.Thread(target=self.maintain_leases)
         self._leaser.daemon = True
         self._leaser.start()
@@ -168,8 +168,8 @@ def on_response(self, response):
         For each message, schedule a callback with the executor.
         """
         for msg in response.received_messages:
-            logger.debug('New message received from Pub/Sub: %r', msg)
-            logger.debug(self._callback)
+            _LOGGER.debug('New message received from Pub/Sub: %r', msg)
+            _LOGGER.debug(self._callback)
             message = Message(msg.message, msg.ack_id, self._request_queue)
             future = self._executor.submit(self._callback, message)
             future.add_done_callback(_callback_completed)