Stop probing user created attributes

comnik · Apr 18, 2019 · a73c867 · a73c867
1 parent 8a48a22
commit a73c867
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/src/domain/mod.rs b/src/domain/mod.rs
@@ -78,7 +78,7 @@ where
 
             self.input_sessions.insert(name.to_string(), session);
 
-            self.create_sourced_attribute(name, config, &pairs)?;
+            self.create_sourced_attribute(name, config, false, &pairs)?;
 
             Ok(())
         }
@@ -91,6 +91,7 @@ where
         &mut self,
         name: &str,
         config: AttributeConfig,
+        probe_progress: bool,
         pairs: &Stream<S, ((Value, Value), T, isize)>,
     ) -> Result<(), Error> {
         if self.forward.contains_key(name) {
@@ -109,8 +110,10 @@ where
                         pairs.as_collection().distinct()
                     }
                 };
-
-                unprobed.probe_with(&mut self.probe)
+                match probe_progress {
+                    true => unprobed.probe_with(&mut self.probe),
+                    false => unprobed,
+                }
             };
 
             self.attributes.insert(name.to_string(), config);

diff --git a/src/server/mod.rs b/src/server/mod.rs
@@ -418,7 +418,7 @@ where
         for (aid, config, datoms) in attribute_streams.drain(..) {
             self.context
                 .internal
-                .create_sourced_attribute(&aid, config, &datoms)?;
+                .create_sourced_attribute(&aid, config, true, &datoms)?;
         }
 
         Ok(())