From e5b0d6cc998bea982249cd3355e0ca082bedce9a Mon Sep 17 00:00:00 2001 From: Dougal Dobie Date: Fri, 26 Jul 2024 13:49:54 +1000 Subject: [PATCH] Add some logging to partially address #718 --- vast_pipeline/pipeline/utils.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/vast_pipeline/pipeline/utils.py b/vast_pipeline/pipeline/utils.py index 15902f31..6d52e1ab 100644 --- a/vast_pipeline/pipeline/utils.py +++ b/vast_pipeline/pipeline/utils.py @@ -1477,11 +1477,15 @@ def reconstruct_associtaion_dfs( """ prev_associations = pd.read_parquet(previous_parquet_paths['associations']) + logger.debug(images_df_done) + logger.debug(images_df_done['image_dj']) + # Get the parquet paths from the image objects img_meas_paths = ( images_df_done['image_dj'].apply(lambda x: x.measurements_path) .to_list() ) + logger.debug(img_meas_paths) # Obtain the pipeline run path in order to fetch forced measurements. run_path = previous_parquet_paths['sources'].replace(