added a sbid to archive copy path

tjgalvin · Aug 24, 2024 · c1ff9d0 · c1ff9d0
1 parent b5af69c
commit c1ff9d0
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/flint/prefect/flows/continuum_pipeline.py b/flint/prefect/flows/continuum_pipeline.py
@@ -478,6 +478,13 @@ def setup_run_process_science_field(
 
     science_sbid = get_sbid_from_path(path=science_path)
 
+    if field_options.sbid_copy_path:
+        updated_sbid_copy_path = field_options.sbid_copy_path / f"{science_sbid}"
+        logger.info(f"Updating archive copy path to {updated_sbid_copy_path=}")
+        field_options = field_options.with_options(
+            sbid_copy_path=updated_sbid_copy_path
+        )
+
     dask_task_runner = get_dask_runner(cluster=cluster_config)
 
     process_science_fields.with_options(