temp debugging

Author: keelerm84

Makefile

@@ -1,4 +1,4 @@
-PYTEST_FLAGS=-W error::SyntaxWarning
+PYTEST_FLAGS=-W error::SyntaxWarning -s
 
 TEMP_TEST_OUTPUT=/tmp/contract-test-service.log
 
@@ -28,12 +28,12 @@ install:
 .PHONY: test
 test: #! Run unit tests
 test: install
-	@LD_SKIP_DATABASE_TESTS=1 poetry run pytest $(PYTEST_FLAGS)
+	@LD_SKIP_DATABASE_TESTS=1 poetry run pytest $(PYTEST_FLAGS) ldclient/testing/impl/datasystem/test_fdv2_datasystem.py::test_two_phase_init
 
 .PHONY: test-all
 test-all: #! Run unit tests (including database integrations)
 test-all: install
-	@poetry run pytest $(PYTEST_FLAGS)
+	@poetry run pytest $(PYTEST_FLAGS) ldclient/testing/impl/datasystem/test_fdv2_datasystem.py::test_two_phase_init
 
 .PHONY: lint
 lint: #! Run type analysis and linting checks

ldclient/impl/datasystem/fdv2.py

@@ -307,6 +307,7 @@ def _run_initializers(self, set_on_ready: Event):
                 log.info("Attempting to initialize via %s", initializer.name)
 
                 basis_result = initializer.fetch(self._store)
+                print("@@@@@@", "init", basis_result, "\n")
 
                 if isinstance(basis_result, _Fail):
                     log.warning("Initializer %s failed: %s", initializer.name, basis_result.error)
@@ -446,6 +447,7 @@ def _consume_synchronizer_results(
         def reader(self: 'FDv2'):
             try:
                 for update in synchronizer.sync(self._store):
+                    print("@@@@@@", "update is at", update, "\n")
                     action_queue.put(update)
             finally:
                 action_queue.put("quit")

ldclient/testing/impl/datasystem/test_fdv2_datasystem.py

@@ -36,13 +36,14 @@ def listener(flag_change: FlagChange):
         count += 1
         changes.append(flag_change)
 
-        if count == 2:
+        if count >= 2:
             changed.set()
 
     fdv2.flag_tracker.add_listener(listener)
 
     fdv2.start(set_on_ready)
     assert set_on_ready.wait(1), "Data system did not become ready in time"
+    changed.clear()
 
     td_synchronizer.update(td_synchronizer.flag("feature-flag").on(False))
     assert changed.wait(1), "Flag change listener was not called in time"