diff --git a/daemon/job/sink.go b/daemon/job/sink.go index 18c009c..627b999 100644 --- a/daemon/job/sink.go +++ b/daemon/job/sink.go @@ -76,7 +76,7 @@ outer: connId++ connLog := log. WithField("connID", connId) - j.handleConnection(WithLogger(ctx, connLog), res.conn) + go j.handleConnection(WithLogger(ctx, connLog), res.conn) case <-ctx.Done(): break outer