From 838d4ab64526497fd2c7cb9f6a55d08e605b4759 Mon Sep 17 00:00:00 2001 From: legosandorigami Date: Thu, 15 Aug 2024 21:48:05 +0000 Subject: [PATCH] feat: subscribe to the correct event name when registering a docker scaler --- 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)