temp debugging

Author: keelerm84

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"