diff --git a/pometry-storage-private b/pometry-storage-private
index 6b90b9179b..93d65fd68d 160000
--- a/pometry-storage-private
+++ b/pometry-storage-private
@@ -1 +1 @@
-Subproject commit 6b90b9179b265a4df4db352b18f5a9105b71b4e6
+Subproject commit 93d65fd68de26bc1f2702a932cfbc3b4998256ce
diff --git a/raphtory-cypher/examples/raphtory_cypher.rs b/raphtory-cypher/examples/raphtory_cypher.rs
index 8359add122..f0c1084a28 100644
--- a/raphtory-cypher/examples/raphtory_cypher.rs
+++ b/raphtory-cypher/examples/raphtory_cypher.rs
@@ -116,6 +116,7 @@ mod cypher {
         src_col: String,
         dst_col: String,
         time_col: String,
+        exclude: Option<Vec<String>>,
     }
 
     impl std::str::FromStr for ArgLayer {
@@ -182,6 +183,7 @@ mod cypher {
                                 src_col,
                                 dst_col,
                                 time_col,
+                                exclude: exclude_edge_props,
                             },
                         ) = &layers[layer_id];
                         ParquetLayerCols {
@@ -190,6 +192,11 @@ mod cypher {
                             src_col: &src_col,
                             dst_col: &dst_col,
                             time_col: &time_col,
+                            exclude_edge_props: exclude_edge_props
+                                .into_iter()
+                                .flatten()
+                                .map(|s| s.as_str())
+                                .collect(),
                         }
                     })
                     .collect();
diff --git a/raphtory-cypher/src/lib.rs b/raphtory-cypher/src/lib.rs
index 93dbaa36ac..8cfac930fe 100644
--- a/raphtory-cypher/src/lib.rs
+++ b/raphtory-cypher/src/lib.rs
@@ -337,6 +337,7 @@ mod cypher {
                         src_col: "source",
                         dst_col: "destination",
                         time_col: "time",
+                        exclude_edge_props: vec!["destination_port"],
                     },
                     ParquetLayerCols {
                         parquet_dir: v1_layer_path.to_str().unwrap(),
@@ -344,6 +345,7 @@ mod cypher {
                         src_col: "src",
                         dst_col: "dst",
                         time_col: "epoch_time",
+                        exclude_edge_props: vec![],
                     },
                 ];
 
diff --git a/raphtory/src/disk_graph/graph_impl/mod.rs b/raphtory/src/disk_graph/graph_impl/mod.rs
index 2bcaef235d..2ce2320b73 100644
--- a/raphtory/src/disk_graph/graph_impl/mod.rs
+++ b/raphtory/src/disk_graph/graph_impl/mod.rs
@@ -15,6 +15,7 @@ pub struct ParquetLayerCols<'a> {
     pub src_col: &'a str,
     pub dst_col: &'a str,
     pub time_col: &'a str,
+    pub exclude_edge_props: Vec<&'a str>,
 }
 
 impl Graph {
@@ -401,6 +402,7 @@ mod test {
                 src_col: "source",
                 dst_col: "destination",
                 time_col: "time",
+                exclude_edge_props: vec![],
             },
             ParquetLayerCols {
                 parquet_dir: v1_layer_path.to_str().unwrap(),
@@ -408,6 +410,7 @@ mod test {
                 src_col: "src",
                 dst_col: "dst",
                 time_col: "Time",
+                exclude_edge_props: vec![],
             },
         ];
 
diff --git a/raphtory/src/disk_graph/mod.rs b/raphtory/src/disk_graph/mod.rs
index 65cecd6498..64587be6f3 100644
--- a/raphtory/src/disk_graph/mod.rs
+++ b/raphtory/src/disk_graph/mod.rs
@@ -340,7 +340,7 @@ impl DiskGraphStorage {
         node_type_col: Option<&str>,
     ) -> Result<DiskGraphStorage, RAError> {
         let layered_edge_list: Vec<ExternalEdgeList<&Path>> = layer_parquet_cols
-            .iter()
+            .into_iter()
             .map(
                 |ParquetLayerCols {
                      parquet_dir,
@@ -348,9 +348,17 @@ impl DiskGraphStorage {
                      src_col,
                      dst_col,
                      time_col,
+                     exclude_edge_props,
                  }| {
-                    ExternalEdgeList::new(layer, parquet_dir.as_ref(), src_col, dst_col, time_col)
-                        .expect("Failed to load events")
+                    ExternalEdgeList::new(
+                        layer,
+                        parquet_dir.as_ref(),
+                        src_col,
+                        dst_col,
+                        time_col,
+                        exclude_edge_props,
+                    )
+                    .expect("Failed to load events")
                 },
             )
             .collect::<Vec<_>>();
diff --git a/raphtory/src/python/graph/disk_graph.rs b/raphtory/src/python/graph/disk_graph.rs
index 257fbad73d..69fcce81d5 100644
--- a/raphtory/src/python/graph/disk_graph.rs
+++ b/raphtory/src/python/graph/disk_graph.rs
@@ -90,6 +90,10 @@ impl<'a> FromPyObject<'a> for ParquetLayerCols<'a> {
                 .get_item("time_col")
                 .and_then(|item| item.expect("time_col is required").extract::<&PyString>())
                 .and_then(|s| s.to_str())?,
+            exclude_edge_props: dict.get_item("exclude_edge_props").and_then(|item| {
+                item.map(|item| item.extract::<Vec<&str>>())
+                    .unwrap_or_else(|| Ok(vec![]))
+            })?,
         })
     }
 }