diff --git a/lib/process-manager.js b/lib/process-manager.js
index e2885a1847..bd745923c9 100644
--- a/lib/process-manager.js
+++ b/lib/process-manager.js
@@ -162,6 +162,9 @@ class StreamProcessWrapper {
 				throw new Error(`Unrecognized messageType ${messageType}`);
 			}
 		});
+		this.process.on('disconnect', () => {
+			this.destroy();
+		});
 	}
 
 	deleteStream(/** @type {number} */ taskId) {