diff --git a/ee/orchestration/cmd/root.go b/ee/orchestration/cmd/root.go
index 065474c4b1..09161d71d4 100644
--- a/ee/orchestration/cmd/root.go
+++ b/ee/orchestration/cmd/root.go
@@ -85,6 +85,7 @@ func NewRootCommand() *cobra.Command {
 	auth.InitAuthFlags(cmd.PersistentFlags())
 	bunconnect.InitFlags(cmd.PersistentFlags())
 	iam.InitFlags(cmd.PersistentFlags())
+	publish.InitCLIFlags(cmd)
 
 	return cmd
 }
diff --git a/ee/orchestration/cmd/worker.go b/ee/orchestration/cmd/worker.go
index c3361af746..8f79b8d9cc 100644
--- a/ee/orchestration/cmd/worker.go
+++ b/ee/orchestration/cmd/worker.go
@@ -1,6 +1,7 @@
 package cmd
 
 import (
+	"github.com/formancehq/stack/libs/go-libs/publish"
 	"net/http"
 
 	"github.com/formancehq/orchestration/internal/triggers"
@@ -33,6 +34,7 @@ func workerOptions() fx.Option {
 			viper.GetString(temporalTaskQueueFlag),
 			viper.GetStringSlice(topicsFlag),
 		),
+		publish.CLIPublisherModule("orchestration"),
 	)
 }