diff --git a/worker/worker.go b/worker/worker.go index 9c2c594..ab4621f 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -89,6 +89,8 @@ func connectToServer(ctx context.Context, uuid uuid.UUID) { c, res, err := websocket.Dial(ctx, conf.Worker.Address+"/worker", &websocket.DialOptions{ HTTPHeader: headers, }) + defer c.CloseNow() + if err != nil { if res != nil { b, _ := io.ReadAll(res.Body)