Invoke destroy when sources finish running (#152)

erdos-project · Mar 11, 2021 · 3bd2f92 · 3bd2f92
1 parent c96b181
commit 3bd2f92
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/src/node/operator_executor.rs b/src/node/operator_executor.rs
@@ -237,16 +237,16 @@ impl OperatorExecutor {
                 .unwrap();
             // Handle errors?
             future::join_all(event_runner_handles).await;
+        }
 
-            if self.all_streams_closed() {
-                slog::debug!(
-                    crate::TERMINAL_LOGGER,
-                    "Node {}: destroying operator {}",
-                    self.config.node_id,
-                    name,
-                );
-                self.operator.destroy();
-            }
+        if self.all_streams_closed() {
+            slog::debug!(
+                crate::TERMINAL_LOGGER,
+                "Node {}: destroying operator {}",
+                self.config.node_id,
+                name,
+            );
+            self.operator.destroy();
         }
     }