Symlink radiology export

SAFEHR-data · Jan 8, 2024 · c32dd88 · c32dd88
1 parent 07fb60f
commit c32dd88
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/pixl_core/src/core/omop.py b/pixl_core/src/core/omop.py
@@ -102,7 +102,14 @@ def export_radiology(self, anon_data: Iterable[tuple]) -> str:
         export_df = pd.DataFrame(anon_data)
         export_df.to_parquet(parquet_file)
 
-        # do symlinks
+        # Make the latest export dir if it doesn't exist
+        self._mkdir(self.latest_parent_dir)
+        # Symlink this report to the latest directory
+        latest_parquet_file = self.latest_parent_dir / "radiology.parquet"
+        if latest_parquet_file.exists():
+            latest_parquet_file.unlink()
+
+        latest_parquet_file.symlink_to(parquet_file, target_is_directory=False)
 
         return self.project_slug