diff --git a/cmd/config_job_source.go b/cmd/config_job_source.go
index 9e2d53c..dba2556 100644
--- a/cmd/config_job_source.go
+++ b/cmd/config_job_source.go
@@ -140,7 +140,7 @@ func (j *SourceJob) serve(ctx context.Context) {
 		conn net.Conn
 		err  error
 	}
-	connChan := make(chan connChanMsg)
+	connChan := make(chan connChanMsg, 1)
 
 	// Serve connections until interrupted or error
 outer: