diff --git a/bin/monitor/delete_composite_objects_and_state.py b/bin/monitor/delete_single_pipeline_state_and_objects.py similarity index 99% rename from bin/monitor/delete_composite_objects_and_state.py rename to bin/monitor/delete_single_pipeline_state_and_objects.py index 6d39e90e3..031f323bf 100644 --- a/bin/monitor/delete_composite_objects_and_state.py +++ b/bin/monitor/delete_single_pipeline_state_and_objects.py @@ -108,4 +108,4 @@ def _email_2_user_list(email_list): if not args.dry_run: logging.info(f"Pipeline delete result is {edb.get_pipeline_state_db().delete_many(pipeline_query).raw_result}") logging.info(f"Composite trip delete result is {edb.get_analysis_timeseries_db().delete_many(trip_query).raw_result}") - edb.get_pipeline_state_db().update_one(pipeline_query, {"$unset": {"curr_run_ts": ""}}) + edb.get_pipeline_state_db().update_one(pipeline_query, {"$set": {"curr_run_ts": None}})