re-enable skipped tests

Author: mredolatti

splitio/sync/manager.py

@@ -99,8 +99,10 @@ def _streaming_feedback_handler(self):
                 self._synchronizer.start_periodic_fetching()
                 _LOGGER.info('streaming temporarily down. starting periodic fetching')
             elif status == Status.PUSH_RETRYABLE_ERROR:
-                self._synchronizer.start_periodic_fetching()
+                self._push.update_workers_status(False)
                 self._push.stop(True)
+                self._synchronizer.sync_all()
+                self._synchronizer.start_periodic_fetching()
                 time.sleep(self._backoff.get())
                 self._push.start()
                 _LOGGER.info('error in streaming. restarting flow')

splitio/tasks/util/asynctask.py

@@ -94,10 +94,8 @@ def _execution_wrapper(self):
                     elif msg == __TASK_FORCE_RUN__:
                         _LOGGER.debug("Force execution signal received. Running now")
                         if not _safe_run(self._main):
-                            _LOGGER.error(
-                                "An error occurred when executing the task. "
-                                "Retrying after perio expires"
-                            )
+                            _LOGGER.error("An error occurred when executing the task. "
+                                          "Retrying after perio expires")
                         continue
                 except queue.Empty:
                     # If no message was received, the timeout has expired

tests/integration/test_streaming_e2e.py

@@ -13,9 +13,7 @@
 except ImportError:
     from urlparse import parse_qs
 
-import pytest
 
-@pytest.mark.skip
 class StreamingIntegrationTests(object):
     """Test streaming operation and failover."""
 
@@ -551,13 +549,7 @@ def test_start_without_occupancy(self):  # pylint: disable=too-many-locals
         assert req.path == '/api/splitChanges?since=1'
         assert req.headers['authorization'] == 'Bearer some_apikey'
 
-        # Fetch after first notification
-        req = split_backend_requests.get()
-        assert req.method == 'GET'
-        assert req.path == '/api/splitChanges?since=1'
-        assert req.headers['authorization'] == 'Bearer some_apikey'
-
-        # Iteration until since == till
+        # Second iteration of previous syncAll
         req = split_backend_requests.get()
         assert req.method == 'GET'
         assert req.path == '/api/splitChanges?since=2'