From 660f572aec955f9ba338c629252a0f0083100b3b Mon Sep 17 00:00:00 2001 From: legosandorigami <141809772+legosandorigami@users.noreply.github.com> Date: Fri, 16 Aug 2024 21:26:07 +0530 Subject: [PATCH] feat: subscribe to the correct event name when registering a docker scaler (#31) Co-authored-by: Vishnu Bharathi --- internal/scaler/docker/docker.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/scaler/docker/docker.go b/internal/scaler/docker/docker.go index 40cd5cc..fec5606 100644 --- a/internal/scaler/docker/docker.go +++ b/internal/scaler/docker/docker.go @@ -37,7 +37,7 @@ func (s *Scaler) Register(ctx context.Context) error { } cli.NegotiateAPIVersion(ctx) - event.B.Subscribe(s.namespacedID, func(_ []byte) { + event.B.Subscribe(fmt.Sprintf("%s.input", s.namespacedID), func(_ []byte) { s.log.Verbose("start") imageFullName := fmt.Sprintf("%s:%s", s.imageName, s.imageTag)