fix: unit test failures in https://github.com/googleapis/python-pubsu…

pytest.ini

@@ -8,5 +8,7 @@ filterwarnings =
     ignore:There is no current event loop:DeprecationWarning:grpc.aio._channel
     # Remove after support for Python 3.7 is dropped
     ignore:After January 1, 2024, new releases of this library will drop support for Python 3.7:DeprecationWarning
-    # Remove warning once https://github.com/googleapis/python-pubsub/issues/1067 is fixed
-    ignore:The return_immediately flag is deprecated and should be set to False.:DeprecationWarning
+    # Remove warning once https://github.com/googleapis/gapic-generator-python/issues/1938 is fixed
+    ignore:The return_immediately flag is deprecated and should be set to False.:DeprecationWarning
+    # Remove warning once https://github.com/googleapis/gapic-generator-python/issues/1939 is fixed
+    ignore:get_mtls_endpoint_and_cert_source is deprecated.:DeprecationWarning

tests/unit/pubsub_v1/conftest.py

@@ -11,16 +11,8 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-import sys
 
 import google.auth.credentials
-
-# special case python < 3.8
-if sys.version_info.major == 3 and sys.version_info.minor < 8:
-    import mock
-else:
-    from unittest import mock
-
 import pytest
 
 
@@ -30,4 +22,4 @@ def creds():
     Provide test creds to unit tests so that they can run without
     GOOGLE_APPLICATION_CREDENTIALS set.
     """
-    yield mock.Mock(spec=google.auth.credentials.Credentials)
+    yield google.auth.credentials.AnonymousCredentials()

tests/unit/pubsub_v1/publisher/batch/test_base.py

@@ -13,13 +13,7 @@
 # limitations under the License.
 
 from __future__ import absolute_import
-import sys
 
-# special case python < 3.8
-if sys.version_info.major == 3 and sys.version_info.minor < 8:
-    import mock
-else:
-    from unittest import mock
 
 from google.auth import credentials
 from google.cloud.pubsub_v1 import publisher
@@ -38,8 +32,7 @@ def create_batch(status, settings=types.BatchSettings()):
     Returns:
         ~.pubsub_v1.publisher.batch.thread.Batch: The batch object
     """
-    creds = mock.Mock(spec=credentials.Credentials)
-    client = publisher.Client(credentials=creds)
+    client = publisher.Client(credentials=credentials.AnonymousCredentials())
     batch = Batch(client, "topic_name", settings)
     batch._status = status
     return batch

tests/unit/pubsub_v1/publisher/batch/test_thread.py

@@ -39,8 +39,7 @@
 
 
 def create_client():
-    creds = mock.Mock(spec=credentials.Credentials)
-    return publisher.Client(credentials=creds)
+    return publisher.Client(credentials=credentials.AnonymousCredentials())
 
 
 def create_batch(

tests/unit/pubsub_v1/publisher/sequencer/test_ordered_sequencer.py

@@ -36,8 +36,7 @@ def create_message():
 
 
 def create_client():
-    creds = mock.Mock(spec=credentials.Credentials)
-    return publisher.Client(credentials=creds)
+    return publisher.Client(credentials=credentials.AnonymousCredentials())
 
 
 def create_ordered_sequencer(client):

tests/unit/pubsub_v1/publisher/sequencer/test_unordered_sequencer.py

@@ -34,8 +34,7 @@ def create_message():
 
 
 def create_client():
-    creds = mock.Mock(spec=credentials.Credentials)
-    return publisher.Client(credentials=creds)
+    return publisher.Client(credentials=credentials.AnonymousCredentials())
 
 
 def test_stop():