diff --git a/.gitignore b/.gitignore index ca613e1..89b67e1 100644 --- a/.gitignore +++ b/.gitignore @@ -2501,3 +2501,4 @@ env/lib/python3.7/site-packages/zipp-3.15.0.dist-info/METADATA env/lib/python3.7/site-packages/zipp-3.15.0.dist-info/RECORD env/lib/python3.7/site-packages/zipp-3.15.0.dist-info/top_level.txt env/lib/python3.7/site-packages/zipp-3.15.0.dist-info/WHEEL +.DS_Store diff --git a/recon_lw/EventsSaver.py b/recon_lw/EventsSaver.py index fff0365..0788e57 100644 --- a/recon_lw/EventsSaver.py +++ b/recon_lw/EventsSaver.py @@ -16,10 +16,13 @@ def flush(self): def flush_scope(self, scope): if scope in self._scopes_buffers: + ts_start = datetime.now().timestamp() events = Data(self._scopes_buffers[scope]) events_file = Path(self._path) / (scope + "_scope_" + self._scopes_buffers[scope][0]["eventId"] + ".pickle") events.build_cache(events_file) self._scopes_buffers[scope].clear() + ts_end = datetime.now().timestamp() + print (datetime.now(), " Saved local events for ", scope, ", duration: ", ts_end - ts_start) def save_events(self, batch): for e in batch: