diff --git a/internal/temporalcli/commands.activity.go b/internal/temporalcli/commands.activity.go index e761e14b2..5f6b95421 100644 --- a/internal/temporalcli/commands.activity.go +++ b/internal/temporalcli/commands.activity.go @@ -51,7 +51,7 @@ func (c *TemporalActivityStartCommand) run(cctx *CommandContext, args []string) if err != nil { return err } - return printActivityExecution(cctx, c.ActivityId, handle.GetRunID(), c.Type, c.Parent.Namespace, c.TaskQueue) + return printActivityExecution(cctx, c.ActivityId, handle.GetRunID(), c.Parent.Namespace) } func (c *TemporalActivityExecuteCommand) run(cctx *CommandContext, args []string) error { @@ -66,7 +66,7 @@ func (c *TemporalActivityExecuteCommand) run(cctx *CommandContext, args []string return err } if !cctx.JSONOutput { - if err := printActivityExecution(cctx, c.ActivityId, handle.GetRunID(), c.Type, c.Parent.Namespace, c.TaskQueue); err != nil { + if err := printActivityExecution(cctx, c.ActivityId, handle.GetRunID(), c.Parent.Namespace); err != nil { cctx.Logger.Error("Failed printing execution info", "error", err) } } @@ -108,22 +108,18 @@ func startActivity( return handle, nil } -func printActivityExecution(cctx *CommandContext, activityID, runID, activityType, namespace, taskQueue string) error { +func printActivityExecution(cctx *CommandContext, activityID, runID, namespace string) error { if !cctx.JSONOutput { cctx.Printer.Println(color.MagentaString("Running execution:")) } return cctx.Printer.PrintStructured(struct { ActivityId string `json:"activityId"` RunId string `json:"runId"` - Type string `json:"type"` Namespace string `json:"namespace"` - TaskQueue string `json:"taskQueue"` }{ ActivityId: activityID, RunId: runID, - Type: activityType, Namespace: namespace, - TaskQueue: taskQueue, }, printer.StructuredOptions{}) } diff --git a/internal/temporalcli/commands.activity_test.go b/internal/temporalcli/commands.activity_test.go index c3ee80c6b..d3a602159 100644 --- a/internal/temporalcli/commands.activity_test.go +++ b/internal/temporalcli/commands.activity_test.go @@ -542,9 +542,7 @@ func (s *SharedServerSuite) TestActivity_Start() { s.Contains(out, "Running execution:") s.ContainsOnSameLine(out, "ActivityId", "start-test") s.Contains(out, "RunId") - s.ContainsOnSameLine(out, "Type", "DevActivity") s.ContainsOnSameLine(out, "Namespace", "default") - s.ContainsOnSameLine(out, "TaskQueue", s.Worker().Options.TaskQueue) // JSON res = s.Execute( @@ -561,9 +559,7 @@ func (s *SharedServerSuite) TestActivity_Start() { s.NoError(json.Unmarshal(res.Stdout.Bytes(), &jsonOut)) s.Equal("start-test-json", jsonOut["activityId"]) s.NotEmpty(jsonOut["runId"]) - s.Equal("DevActivity", jsonOut["type"]) s.Equal("default", jsonOut["namespace"]) - s.NotEmpty(jsonOut["taskQueue"]) } func (s *SharedServerSuite) TestActivity_Start_With_Headers() {