[WARP] Enhanced network support

1 files changed, 13 insertions, 2 deletions

diff --git a/plugins/warp/src/container/memory.rs b/plugins/warp/src/container/memory.rs
index cf53390e..51628d6c 100644
--- a/plugins/warp/src/container/memory.rs
+++ b/plugins/warp/src/container/memory.rs
@@ -1,5 +1,7 @@
-use crate::container::{Container, ContainerError, ContainerResult, SourceId, SourcePath};
-use std::collections::HashMap;
+use crate::container::{
+    Container, ContainerError, ContainerResult, SourceId, SourcePath, SourceTag,
+};
+use std::collections::{HashMap, HashSet};
 use std::fmt::Display;
 use warp::r#type::guid::TypeGUID;
 use warp::r#type::{ComputedType, Type};
@@ -73,6 +75,15 @@ impl Container for MemoryContainer {
         Ok(false)
     }
 
+    fn source_tags(&self, source: &SourceId) -> ContainerResult<HashSet<SourceTag>> {
+        let _memory_source = self
+            .sources
+            .get(source)
+            .ok_or(ContainerError::SourceNotFound(*source))?;
+        // NOTE: Memory containers do not have a notion of tags.
+        Ok(HashSet::default())
+    }
+
     fn source_path(&self, source: &SourceId) -> ContainerResult<SourcePath> {
         Err(ContainerError::SourcePathUnavailable(*source))
     }