diff --git a/aeon/dj_pipeline/analysis/block_analysis.py b/aeon/dj_pipeline/analysis/block_analysis.py index db3934a8..4267f883 100644 --- a/aeon/dj_pipeline/analysis/block_analysis.py +++ b/aeon/dj_pipeline/analysis/block_analysis.py @@ -78,7 +78,7 @@ def make(self, key): block_state_query = acquisition.Environment.BlockState & exp_key & chunk_restriction block_state_df = fetch_stream(block_state_query) if block_state_df.empty: - # self.insert1(key) + self.insert1(key) return block_state_df = block_state_df.loc[ @@ -108,7 +108,7 @@ def make(self, key): ) Block.insert(block_entries, skip_duplicates=True) - # self.insert1({**key, "execution_time": datetime.now(UTC)}) + self.insert1({**key, "execution_time": datetime.now(UTC)}) self.IdentifiedBlock.insert( {**key, "block_start": entry["block_start"]} for entry in block_entries )