diff --git a/cmd/homelab-deploy/main.go b/cmd/homelab-deploy/main.go index d01a8ed..71891a0 100644 --- a/cmd/homelab-deploy/main.go +++ b/cmd/homelab-deploy/main.go @@ -16,7 +16,7 @@ import ( "github.com/urfave/cli/v3" ) -const version = "0.1.9" +const version = "0.1.10" func main() { app := &cli.Command{ diff --git a/internal/listener/listener.go b/internal/listener/listener.go index 85be8ea..b30357f 100644 --- a/internal/listener/listener.go +++ b/internal/listener/listener.go @@ -260,6 +260,10 @@ func (l *Listener) handleDeployRequest(subject string, data []byte) { messages.StatusCompleted, "deployment completed successfully", )) + // Flush to ensure the completed response is sent before we potentially restart + if err := l.client.Flush(); err != nil { + l.logger.Error("failed to flush completed response", "error", err) + } if l.metrics != nil { l.metrics.RecordDeploymentEnd(req.Action, true, duration) }