From 522a5c07a2a664d54862ead307253ed105980f9d Mon Sep 17 00:00:00 2001
From: "mayur.popli" <mayur.popli@thewitslab.com>
Date: Wed, 2 Apr 2025 17:03:00 +0530
Subject: [PATCH] error in publisher

---
 pkg/plugin/definition/publisher.go | 2 +-
 pkg/plugin/manager.go              | 8 +++++++-
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/pkg/plugin/definition/publisher.go b/pkg/plugin/definition/publisher.go
index 4eba687..1e744da 100644
--- a/pkg/plugin/definition/publisher.go
+++ b/pkg/plugin/definition/publisher.go
@@ -10,5 +10,5 @@ type Publisher interface {
 
 type PublisherProvider interface {
 	// New initializes a new publisher instance with the given configuration.
-	New(ctx context.Context, config map[string]string) (Publisher, func(), error)
+	New(ctx context.Context, config map[string]string) (Publisher, func() error, error)
 }
diff --git a/pkg/plugin/manager.go b/pkg/plugin/manager.go
index bd969c4..4cb4a37 100644
--- a/pkg/plugin/manager.go
+++ b/pkg/plugin/manager.go
@@ -130,7 +130,13 @@ func (m *Manager) Publisher(ctx context.Context, cfg *Config) (definition.Publis
 	if err != nil {
 		return nil, err
 	}
-	m.addCloser(closer)
+	if closer != nil {
+		m.addCloser(func() {
+			if err := closer(); err != nil {
+				panic(err)
+			}
+		})
+	}
 	return p, nil
 }