diff --git a/restream/core.go b/restream/core.go
index 270b66c8..73a8f282 100644
--- a/restream/core.go
+++ b/restream/core.go
@@ -1236,6 +1236,9 @@ func (r *restream) updateProcess(task *task, config *app.Config) error {
 		return fmt.Errorf("delete process: %w", err)
 	}
 
+	t.Lock()
+	defer t.Unlock()
+
 	r.tasks.Store(tid, t)
 
 	// set filesystem cleanup rules