From f8df346eb673bd20f124bec4bb817391a85f3eba Mon Sep 17 00:00:00 2001
From: Andre Medeiros <hello@andre.cool>
Date: Wed, 2 Nov 2022 02:21:19 -0400
Subject: [PATCH] clean pool on process shutdown

---
 internal/cmd/worker.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go
index 514a8a8..5c7d118 100644
--- a/internal/cmd/worker.go
+++ b/internal/cmd/worker.go
@@ -62,6 +62,7 @@ func WorkerCmd(ctx context.Context) *cobra.Command {
 			if err != nil {
 				return err
 			}
+			defer fp.Close()
 
 			mgr := faktoryworker.NewManager()
 			mgr.Concurrency = consumers