pytest.mark.network

tests/test_requests_futures.py

@@ -13,6 +13,7 @@
     pypy_version_info = None
 from unittest import TestCase, main, skipIf
 import logging
+import pytest
 
 from requests import Response, session
 from requests.adapters import DEFAULT_POOLSIZE
@@ -30,6 +31,7 @@ def httpbin(*suffix):
 
 
 class RequestsTestCase(TestCase):
+    @pytest.mark.network
     def test_futures_session(self):
         # basic futures get
         sess = FuturesSession()
@@ -65,6 +67,7 @@ def rasing_cb(s, r):
             resp = future.result()
         self.assertEqual('boom', cm.exception.args[0])
 
+    @pytest.mark.network
     def test_supplied_session(self):
         """Tests the `session` keyword argument."""
         requests_session = session()
@@ -112,6 +115,7 @@ def test_adapter_kwargs(self):
         )
         self.assertEqual(session.get_adapter('http://')._pool_connections, 20)
 
+    @pytest.mark.network
     def test_redirect(self):
         """Tests for the ability to cleanly handle redirects."""
         sess = FuturesSession()
@@ -125,6 +129,7 @@ def test_redirect(self):
         resp = future.result()
         self.assertEqual(404, resp.status_code)
 
+    @pytest.mark.network
     def test_context(self):
         class FuturesSessionTestHelper(FuturesSession):
             def __init__(self, *args, **kwargs):
@@ -181,15 +186,18 @@ def setUp(self):
         self.proc_executor = ProcessPoolExecutor(max_workers=2)
         self.session = session()
 
+    @pytest.mark.network
     @skipIf(session_required, 'not supported in python < 3.5')
     def test_futures_session(self):
         self._assert_futures_session()
 
+    @pytest.mark.network
     @skipIf(not session_required, 'fully supported on python >= 3.5')
     def test_exception_raised(self):
         with self.assertRaises(RuntimeError):
             self._assert_futures_session()
 
+    @pytest.mark.network
     def test_futures_existing_session(self):
         self.session.headers['Foo'] = 'bar'
         self._assert_futures_session(session=self.session)
@@ -247,10 +255,12 @@ def _assert_futures_session(self, session=None):
         resp = future.result()
         self.assertEqual(404, resp.status_code)
 
+    @pytest.mark.network
     @skipIf(session_required, 'not supported in python < 3.5')
     def test_context(self):
         self._assert_context()
 
+    @pytest.mark.network
     def test_context_with_session(self):
         self._assert_context(session=self.session)
 
@@ -285,6 +295,7 @@ def __exit__(self, *args, **kwargs):
 
 @skipIf(not unsupported_platform, 'Exception raised when unsupported')
 class ProcessPoolExceptionRaisedTestCase(TestCase):
+    @pytest.mark.network
     def test_exception_raised(self):
         executor = ProcessPoolExecutor(max_workers=2)
         sess = FuturesSession(executor=executor, session=session())