add some noise

Author: keelerm84

ldclient/impl/integrations/files/file_data_source.py

@@ -80,6 +80,7 @@ def initialized(self):
         return self._inited
 
     def _load_all(self):
+        log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ calling _load_all')
         all_data = { FEATURES: {}, SEGMENTS: {} }
         for path in self._paths:
             try:
@@ -162,11 +163,17 @@ def _start_auto_updater(self):
     # if available for the current platform.
     class WatchdogAutoUpdater:
         def __init__(self, resolved_paths, reloader):
+            log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ calling WatchdogAutoUpdater')
             watched_files = set(resolved_paths)
 
             class LDWatchdogHandler(watchdog.events.FileSystemEventHandler):
                 def on_any_event(self, event):
+                    if isinstance(event, watchdog.events.FileDeletedEvent):
+                        return
+
+                    log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ calling on_any_event with event %s' % event)
                     if event.src_path in watched_files:
+                        log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ calling reloader')
                         reloader()
 
             dir_paths = set()

ldclient/testing/test_file_data_source.py

@@ -2,6 +2,8 @@
 import os
 from typing import List
 
+from ldclient.impl.util import log
+
 import pytest
 import tempfile
 import threading
@@ -117,8 +119,11 @@ def make_temp_file(content):
     return path
 
 def replace_file(path, content):
+    log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ making a new temp file')
     temp_path = make_temp_file(content)
+    log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ renaming temp file from %s to %s' % (temp_path, path))
     os.rename(temp_path, path)
+    log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ done')
 
 def test_does_not_load_data_prior_to_start():
     path = make_temp_file('{"flagValues":{"key":"value"}}')
@@ -235,13 +240,17 @@ def test_does_not_reload_modified_file_if_auto_update_is_off():
         os.remove(path)
 
 def do_auto_update_test(options):
+    log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ preparing to make flag file')
     path = make_temp_file(flag_only_json)
+    log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ flag file made with path %s' % path)
     options['paths'] = path
     try:
         source = make_data_source(Config("SDK_KEY"), **options)
+        log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ starting the data source')
         source.start()
         assert len(store.all(SEGMENTS, lambda x: x)) == 0
         time.sleep(0.5)
+        log.error('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ replacing the file')
         replace_file(path, segment_only_json)
         deadline = time.time() + 20
         while time.time() < deadline: