added skipif for api_core version

Author: daniel-sanche

tests/system/test_retry_streaming.py

@@ -18,6 +18,10 @@
 from datetime import timedelta
 from google.api_core import retry as retries
 from google.api_core import exceptions as core_exceptions
+from google.api_core.version import __version__ as api_core_version
+
+if [int(n) for n in api_core_version.split(".")] < [2, 16, 0]:
+    pytest.skip("streaming retries requires api_core v2.16.0+", allow_module_level=True)
 
 
 def _code_from_exc(exc):

tests/system/test_retry_streaming_async.py

@@ -18,9 +18,13 @@
 from datetime import timedelta
 from google.api_core import retry as retries
 from google.api_core import exceptions as core_exceptions
+from google.api_core.version import __version__ as api_core_version
 
 from test_retry_streaming import _code_from_exc
 
+if [int(n) for n in api_core_version.split(".")] < [2, 16, 0]:
+    pytest.skip("streaming retries requires api_core v2.16.0+", allow_module_level=True)
+
 
 @pytest.mark.asyncio
 async def test_async_streaming_retry_success(async_sequence):