Skip to content

Commit

Permalink
Removed continue_on_error parameter to load timeseries function
Browse files Browse the repository at this point in the history
This was causing the exception handling to kick in with the flag considered and no data was being inserted in the database
  • Loading branch information
Mahadik, Mukul Chandrakant authored and Mahadik, Mukul Chandrakant committed Aug 1, 2024
1 parent 1b6833d commit 306f4de
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion emission/purge_restore/restore_data.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,4 +35,5 @@ def run_restore_data_pipeline(self, user_id, file_name):
time_query = espq.get_time_range_for_restore_data(user_id)
entries = json.load(gzip.open(file_name + ".gz"), object_hook = esj.wrapped_object_hook)
self._last_processed_ts = entries[-1]['metadata']['write_ts']
lmtfr.load_multi_timeline_for_range(file_name, continue_on_error=True)
# lmtfr.load_multi_timeline_for_range(file_name, continue_on_error=True)
lmtfr.load_multi_timeline_for_range(file_name)

0 comments on commit 306f4de

Please sign in to comment.