Fix wrong UUID length for initial source creation.

askap-vast · Feb 6, 2025 · 9deef39 · 9deef39
1 parent d22384e
commit 9deef39
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/vast_pipeline/pipeline/forced_extraction.py b/vast_pipeline/pipeline/forced_extraction.py
@@ -372,7 +372,6 @@ def parallel_extraction(
     out = out.drop(["max_snr", "image_rms_min", "detection"], axis=1).rename(
         columns={"image": "image_name"}
     )
-    out.to_parquet('/scratch2/v2.0/forced_out_L375.parquet')
     # get the unique images to extract from
     unique_images_to_extract = out["image_name"].unique().tolist()
 

diff --git a/vast_pipeline/pipeline/utils.py b/vast_pipeline/pipeline/utils.py
@@ -29,7 +29,7 @@
 from vast_pipeline.utils.utils import (
     eq_to_cart, StopWatch, optimise_numeric,
     calculate_workers_and_partitions, copy_file_or_dir,
-    delete_file_or_dir, generate_shortuuid, UUID_LEN_MEAS
+    delete_file_or_dir, generate_shortuuid, UUID_LEN_SOURCE
 )
 from vast_pipeline.models import (
     Band, Image, Run, SkyRegion
@@ -340,7 +340,7 @@ def _load_measurements(
     df["image"] = image.name
     df["datetime"] = image.datetime
     # these are the first 'sources' if ini_df is True.
-    df["source"] = df["id"].apply(lambda _: generate_shortuuid(UUID_LEN_MEAS)) if ini_df else None
+    df["source"] = df["id"].apply(lambda _: generate_shortuuid(UUID_LEN_SOURCE)) if ini_df else None
     df["ra_source"] = df["ra"]
     df["dec_source"] = df["dec"]
     df["d2d"] = 0.0