worker: fix publish subject - should be suffix and not the whole

metal-toolbox · Jun 2, 2023 · 54c65e5 · 54c65e5
1 parent af40c5b
commit 54c65e5
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/internal/worker/worker.go b/internal/worker/worker.go
@@ -405,10 +405,9 @@ func (e *statusEmitter) Publish(hCtx *sm.HandlerContext, task *model.Task) {
 		panic("unable to marshal a condition update" + err.Error())
 	}
 
-	subject := fmt.Sprintf("com.hollow.sh.controllers.responses.%s.update", hCtx.FacilityCode)
 	if err := e.stream.Publish(
 		hCtx.Ctx,
-		subject,
+		string(cptypes.FirmwareInstall),
 		byt,
 	); err != nil {
 		e.logger.WithError(err).Error("error publishing condition update")