debugging test

Author: chillaq

tests/integration/test_client_e2e.py

@@ -943,54 +943,6 @@ def setup_method(self):
 class LocalhostIntegrationTests(object):  # pylint: disable=too-few-public-methods
     """Client & Manager integration tests."""
 
-    def test_incorrect_file_e2e(self):
-        factory = get_factory('localhost', config={'splitFile': 'filename'})
-        exception_raised = False
-        try:
-            factory.block_until_ready(1)
-        except TimeoutException as e:
-            exception_raised = True
-
-        assert(exception_raised)
-
-        event = threading.Event()
-        factory.destroy(event)
-        event.wait()
-
-    def test_localhost_e2e(self):
-        """Instantiate a client with a YAML file and issue get_treatment() calls."""
-        filename = os.path.join(os.path.dirname(__file__), 'files', 'file2.yaml')
-        factory = get_factory('localhost', config={'splitFile': filename})
-        factory.block_until_ready()
-        client = factory.client()
-        assert client.get_treatment_with_config('key', 'my_feature') == ('on', '{"desc" : "this applies only to ON treatment"}')
-        assert client.get_treatment_with_config('only_key', 'my_feature') == (
-            'off', '{"desc" : "this applies only to OFF and only for only_key. The rest will receive ON"}'
-        )
-        assert client.get_treatment_with_config('another_key', 'my_feature') == ('control', None)
-        assert client.get_treatment_with_config('key2', 'other_feature') == ('on', None)
-        assert client.get_treatment_with_config('key3', 'other_feature') == ('on', None)
-        assert client.get_treatment_with_config('some_key', 'other_feature_2') == ('on', None)
-        assert client.get_treatment_with_config('key_whitelist', 'other_feature_3') == ('on', None)
-        assert client.get_treatment_with_config('any_other_key', 'other_feature_3') == ('off', None)
-
-        manager = factory.manager()
-        assert manager.split('my_feature').configs == {
-            'on': '{"desc" : "this applies only to ON treatment"}',
-            'off': '{"desc" : "this applies only to OFF and only for only_key. The rest will receive ON"}'
-        }
-        assert manager.split('other_feature').configs == {}
-        assert manager.split('other_feature_2').configs == {}
-        assert manager.split('other_feature_3').configs == {}
-        event = threading.Event()
-        factory.destroy(event)
-        event.wait()
-
-        # hack to increase isolation and prevent conflicts with other tests
-#        thread = factory._sync_manager._synchronizer._split_tasks.split_task._task._thread
-#        if thread is not None and thread.is_alive():
-#            thread.join()
-
     def test_localhost_json_e2e(self):
         """Instantiate a client with a JSON file and issue get_treatment() calls."""
         filename = os.path.join(os.path.dirname(__file__), 'files', 'split_changes_temp.json')
@@ -1118,3 +1070,46 @@ def _synchronize_now(self):
         filename = os.path.join(os.path.dirname(__file__), 'files', 'split_changes_temp.json')
         self.factory._sync_manager._synchronizer._split_synchronizers._split_sync._filename = filename
         self.factory._sync_manager._synchronizer._split_synchronizers._split_sync.synchronize_splits()
+
+    def test_incorrect_file_e2e(self):
+        factory = get_factory('localhost', config={'splitFile': 'filename'})
+        exception_raised = False
+        try:
+            factory.block_until_ready(1)
+        except TimeoutException as e:
+            exception_raised = True
+
+        assert(exception_raised)
+
+        event = threading.Event()
+        factory.destroy(event)
+        event.wait()
+
+    def test_localhost_e2e(self):
+        """Instantiate a client with a YAML file and issue get_treatment() calls."""
+        filename = os.path.join(os.path.dirname(__file__), 'files', 'file2.yaml')
+        factory = get_factory('localhost', config={'splitFile': filename})
+        factory.block_until_ready()
+        client = factory.client()
+        assert client.get_treatment_with_config('key', 'my_feature') == ('on', '{"desc" : "this applies only to ON treatment"}')
+        assert client.get_treatment_with_config('only_key', 'my_feature') == (
+            'off', '{"desc" : "this applies only to OFF and only for only_key. The rest will receive ON"}'
+        )
+        assert client.get_treatment_with_config('another_key', 'my_feature') == ('control', None)
+        assert client.get_treatment_with_config('key2', 'other_feature') == ('on', None)
+        assert client.get_treatment_with_config('key3', 'other_feature') == ('on', None)
+        assert client.get_treatment_with_config('some_key', 'other_feature_2') == ('on', None)
+        assert client.get_treatment_with_config('key_whitelist', 'other_feature_3') == ('on', None)
+        assert client.get_treatment_with_config('any_other_key', 'other_feature_3') == ('off', None)
+
+        manager = factory.manager()
+        assert manager.split('my_feature').configs == {
+            'on': '{"desc" : "this applies only to ON treatment"}',
+            'off': '{"desc" : "this applies only to OFF and only for only_key. The rest will receive ON"}'
+        }
+        assert manager.split('other_feature').configs == {}
+        assert manager.split('other_feature_2').configs == {}
+        assert manager.split('other_feature_3').configs == {}
+        event = threading.Event()
+        factory.destroy(event)
+        event.wait()