diff --git a/app/run.go b/app/run.go
index cc029590..2c4903c2 100644
--- a/app/run.go
+++ b/app/run.go
@@ -215,7 +215,6 @@ func (app *App) processEvent(
 		}()
 	} else {
 		app.logger.Warn("Logs collection not started due to earlier subscription failure")
-		close(logProcessingDone)
 	}
 
 	// Calculate how long to wait for a runtimeDoneSignal or AgentDoneSignal signal