Using projectOutputBuffers to check for jobID instead of receiverBuff…

…ers (#181)
lyft · Feb 4, 2022 · 8e9bda2 · 8e9bda2
1 parent fa3ebfc
commit 8e9bda2
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/server/handlers/project_command_output_handler.go b/server/handlers/project_command_output_handler.go
@@ -117,9 +117,9 @@ func NewAsyncProjectCommandOutputHandler(
 }
 
 func (p *AsyncProjectCommandOutputHandler) IsKeyExists(key string) bool {
-	p.receiverBuffersLock.RLock()
-	defer p.receiverBuffersLock.RUnlock()
-	_, ok := p.receiverBuffers[key]
+	p.projectOutputBuffersLock.RLock()
+	defer p.projectOutputBuffersLock.RUnlock()
+	_, ok := p.projectOutputBuffers[key]
 	return ok
 }