Update worker/worker.go

Cleanup Websocket connections to prevent FD leak
2025-05-31 22:13:03 +00:00 · 2025-05-31 22:13:03 +00:00 · 3f27f5c943
commit 3f27f5c943
parent cf7827c120
1 changed files with 2 additions and 0 deletions
--- 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)