diff --git a/src/node/operator_executor.rs b/src/node/operator_executor.rs
index 3e717a4a..04a99ac1 100644
--- 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();
         }
     }