Obtain status file lock when updating full status

Co-authored-by: Seth Foster <fosterseth@users.noreply.github.com>
ansible · May 19, 2021 · 14dc61f · 14dc61f
1 parent 6c98eb7
commit 14dc61f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/workceptor/workunitbase.go b/pkg/workceptor/workunitbase.go
@@ -251,6 +251,8 @@ func (sfd *StatusFileData) UpdateFullStatus(filename string, statusFunc func(*St
 // UpdateFullStatus atomically updates the whole status record.  Changes should be made in the callback function.
 // Errors are logged rather than returned.
 func (bwu *BaseWorkUnit) UpdateFullStatus(statusFunc func(*StatusFileData)) {
+	bwu.statusLock.Lock()
+	defer bwu.statusLock.Unlock()
 	err := bwu.status.UpdateFullStatus(bwu.statusFileName, statusFunc)
 	bwu.lastUpdateError = err
 	if err != nil {