Adopting the new Actor API changes.

zoez7 · zoez7 · commit 4104a7d4d063 · 2026-07-08T17:38:13.000-07:00
diff --git a/cmd/ateapi/internal/controlapi/workflow_pause.go b/cmd/ateapi/internal/controlapi/workflow_pause.go
@@ -87,7 +87,7 @@ func (s *MarkPausingStep) IsComplete(ctx context.Context, input *PauseInput, sta
 func (s *MarkPausingStep) CheckPrerequisite(ctx context.Context, input *PauseInput, state *PauseState) error {
 	// The pause edge only exists from RUNNING; PAUSING/PAUSED are fast-forwarded by IsComplete.
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RUNNING {
-		return status.Errorf(codes.FailedPrecondition, "MarkPausingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)
+		return status.Errorf(codes.FailedPrecondition, "MarkPausingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)
 	}
 	return nil
 }
@@ -116,7 +116,7 @@ func (s *CallAteletPauseStep) IsComplete(ctx context.Context, input *PauseInput,
 }
 func (s *CallAteletPauseStep) CheckPrerequisite(ctx context.Context, input *PauseInput, state *PauseState) error {
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_PAUSING {
-		return status.Errorf(codes.FailedPrecondition, "CallAteletPauseStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)
+		return status.Errorf(codes.FailedPrecondition, "CallAteletPauseStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)
 	}
 	return nil
 }
@@ -175,7 +175,7 @@ func (s *FinalizePausedStep) IsComplete(ctx context.Context, input *PauseInput,
 }
 func (s *FinalizePausedStep) CheckPrerequisite(ctx context.Context, input *PauseInput, state *PauseState) error {
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_PAUSING {
-		return status.Errorf(codes.FailedPrecondition, "FinalizePausedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)
+		return status.Errorf(codes.FailedPrecondition, "FinalizePausedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)
 	}
 	return nil
 }
diff --git a/cmd/ateapi/internal/controlapi/workflow_pause_test.go b/cmd/ateapi/internal/controlapi/workflow_pause_test.go
@@ -136,7 +136,7 @@ func TestPauseSteps_CheckPrerequisite(t *testing.T) {
 		t.Run(tc.name, func(t *testing.T) {
 			ctx := context.Background()
 			for _, st := range allActorStatuses {
-				err := tc.step.CheckPrerequisite(ctx, &PauseInput{ActorID: "id1"}, &PauseState{Actor: &ateapipb.Actor{Status: st}})
+				err := tc.step.CheckPrerequisite(ctx, &PauseInput{ActorName: "id1"}, &PauseState{Actor: &ateapipb.Actor{Status: st}})
 				assertPrerequisiteResult(t, st, err, tc.allowed == nil || tc.allowed[st])
 			}
 		})
diff --git a/cmd/ateapi/internal/controlapi/workflow_resume.go b/cmd/ateapi/internal/controlapi/workflow_resume.go
@@ -128,7 +128,7 @@ func (s *AssignWorkerStep) CheckPrerequisite(ctx context.Context, input *ResumeI
 	case ateapipb.Actor_STATUS_SUSPENDED, ateapipb.Actor_STATUS_PAUSED, ateapipb.Actor_STATUS_RESUMING:
 		return nil
 	default:
-		return status.Errorf(codes.FailedPrecondition, "AssignWorkerStep prerequisite not met for Actor: %s (got: %v, want %s, %s or %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDED, ateapipb.Actor_STATUS_PAUSED, ateapipb.Actor_STATUS_RESUMING)
+		return status.Errorf(codes.FailedPrecondition, "AssignWorkerStep prerequisite not met for Actor: %s (got: %v, want %s, %s or %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDED, ateapipb.Actor_STATUS_PAUSED, ateapipb.Actor_STATUS_RESUMING)
 	}
 }
 
@@ -273,7 +273,7 @@ func (s *CallAteletRestoreStep) IsComplete(ctx context.Context, input *ResumeInp
 }
 func (s *CallAteletRestoreStep) CheckPrerequisite(ctx context.Context, input *ResumeInput, state *ResumeState) error {
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RESUMING {
-		return status.Errorf(codes.FailedPrecondition, "CallAteletRestoreStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)
+		return status.Errorf(codes.FailedPrecondition, "CallAteletRestoreStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)
 	}
 	return nil
 }
@@ -383,7 +383,7 @@ func (s *FinalizeRunningStep) IsComplete(ctx context.Context, input *ResumeInput
 }
 func (s *FinalizeRunningStep) CheckPrerequisite(ctx context.Context, input *ResumeInput, state *ResumeState) error {
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RESUMING {
-		return status.Errorf(codes.FailedPrecondition, "FinalizeRunningStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)
+		return status.Errorf(codes.FailedPrecondition, "FinalizeRunningStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)
 	}
 	return nil
 }
diff --git a/cmd/ateapi/internal/controlapi/workflow_resume_test.go b/cmd/ateapi/internal/controlapi/workflow_resume_test.go
@@ -288,7 +288,7 @@ func TestResumeSteps_CheckPrerequisite(t *testing.T) {
 		t.Run(tc.name, func(t *testing.T) {
 			ctx := context.Background()
 			for _, st := range allActorStatuses {
-				err := tc.step.CheckPrerequisite(ctx, &ResumeInput{ActorID: "id1"}, &ResumeState{Actor: &ateapipb.Actor{Status: st}})
+				err := tc.step.CheckPrerequisite(ctx, &ResumeInput{ActorName: "id1"}, &ResumeState{Actor: &ateapipb.Actor{Status: st}})
 				assertPrerequisiteResult(t, st, err, tc.allowed == nil || tc.allowed[st])
 			}
 		})
diff --git a/cmd/ateapi/internal/controlapi/workflow_suspend.go b/cmd/ateapi/internal/controlapi/workflow_suspend.go
@@ -87,7 +87,7 @@ func (s *MarkSuspendingStep) IsComplete(ctx context.Context, input *SuspendInput
 }
 func (s *MarkSuspendingStep) CheckPrerequisite(ctx context.Context, input *SuspendInput, state *SuspendState) error {
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RUNNING {
-		return status.Errorf(codes.FailedPrecondition, "MarkSuspendingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)
+		return status.Errorf(codes.FailedPrecondition, "MarkSuspendingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)
 	}
 	return nil
 }
@@ -117,7 +117,7 @@ func (s *CallAteletSuspendStep) IsComplete(ctx context.Context, input *SuspendIn
 }
 func (s *CallAteletSuspendStep) CheckPrerequisite(ctx context.Context, input *SuspendInput, state *SuspendState) error {
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_SUSPENDING {
-		return status.Errorf(codes.FailedPrecondition, "CallAteletSuspendStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)
+		return status.Errorf(codes.FailedPrecondition, "CallAteletSuspendStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)
 	}
 	return nil
 }
@@ -176,7 +176,7 @@ func (s *FinalizeSuspendedStep) IsComplete(ctx context.Context, input *SuspendIn
 }
 func (s *FinalizeSuspendedStep) CheckPrerequisite(ctx context.Context, input *SuspendInput, state *SuspendState) error {
 	if state.Actor.GetStatus() != ateapipb.Actor_STATUS_SUSPENDING {
-		return status.Errorf(codes.FailedPrecondition, "FinalizeSuspendedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)
+		return status.Errorf(codes.FailedPrecondition, "FinalizeSuspendedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)
 	}
 	return nil
 }
diff --git a/cmd/ateapi/internal/controlapi/workflow_suspend_test.go b/cmd/ateapi/internal/controlapi/workflow_suspend_test.go
@@ -137,7 +137,7 @@ func TestSuspendSteps_CheckPrerequisite(t *testing.T) {
 		t.Run(tc.name, func(t *testing.T) {
 			ctx := context.Background()
 			for _, st := range allActorStatuses {
-				err := tc.step.CheckPrerequisite(ctx, &SuspendInput{ActorID: "id1"}, &SuspendState{Actor: &ateapipb.Actor{Status: st}})
+				err := tc.step.CheckPrerequisite(ctx, &SuspendInput{ActorName: "id1"}, &SuspendState{Actor: &ateapipb.Actor{Status: st}})
 				assertPrerequisiteResult(t, st, err, tc.allowed == nil || tc.allowed[st])
 			}
 		})
diff --git a/cmd/ateapi/internal/controlapi/workflow_testutil_test.go b/cmd/ateapi/internal/controlapi/workflow_testutil_test.go
@@ -50,16 +50,15 @@ func newTestActorWorkflow(t *testing.T, st store.Interface, tmplNamespace, tmplN
 func seedWorkflowActor(t *testing.T, ctx context.Context, st store.Interface, atespace, id, tmplNamespace, tmplName string, actorStatus ateapipb.Actor_Status, opts ...func(*ateapipb.Actor)) {
 	t.Helper()
 	actor := &ateapipb.Actor{
-		ActorId:                id,
-		Atespace:               atespace,
+		Metadata:               &ateapipb.ResourceMetadata{Name: id, Atespace: atespace},
 		Status:                 actorStatus,
 		ActorTemplateNamespace: tmplNamespace,
 		ActorTemplateName:      tmplName,
 	}
 	for _, opt := range opts {
 		opt(actor)
 	}
-	if err := st.CreateActor(ctx, actor); err != nil {
+	if _, err := st.CreateActor(ctx, actor); err != nil {
 		t.Fatalf("seed actor: %v", err)
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ func (s MarkPausingStep) IsComplete(ctx context.Context, input PauseInput, sta`
`87`	`87`	`func (s MarkPausingStep) CheckPrerequisite(ctx context.Context, input PauseInput, state *PauseState) error {`
`88`	`88`	`// The pause edge only exists from RUNNING; PAUSING/PAUSED are fast-forwarded by IsComplete.`
`89`	`89`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RUNNING {`
`90`		`- return status.Errorf(codes.FailedPrecondition, "MarkPausingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)`
	`90`	`+ return status.Errorf(codes.FailedPrecondition, "MarkPausingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)`
`91`	`91`	`}`
`92`	`92`	`return nil`
`93`	`93`	`}`
`@@ -116,7 +116,7 @@ func (s CallAteletPauseStep) IsComplete(ctx context.Context, input PauseInput,`
`116`	`116`	`}`
`117`	`117`	`func (s CallAteletPauseStep) CheckPrerequisite(ctx context.Context, input PauseInput, state *PauseState) error {`
`118`	`118`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_PAUSING {`
`119`		`- return status.Errorf(codes.FailedPrecondition, "CallAteletPauseStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)`
	`119`	`+ return status.Errorf(codes.FailedPrecondition, "CallAteletPauseStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)`
`120`	`120`	`}`
`121`	`121`	`return nil`
`122`	`122`	`}`
`@@ -175,7 +175,7 @@ func (s FinalizePausedStep) IsComplete(ctx context.Context, input PauseInput,`
`175`	`175`	`}`
`176`	`176`	`func (s FinalizePausedStep) CheckPrerequisite(ctx context.Context, input PauseInput, state *PauseState) error {`
`177`	`177`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_PAUSING {`
`178`		`- return status.Errorf(codes.FailedPrecondition, "FinalizePausedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)`
	`178`	`+ return status.Errorf(codes.FailedPrecondition, "FinalizePausedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_PAUSING)`
`179`	`179`	`}`
`180`	`180`	`return nil`
`181`	`181`	`}`
Original file line number	Diff line number	Diff line change
`@@ -136,7 +136,7 @@ func TestPauseSteps_CheckPrerequisite(t *testing.T) {`
`136`	`136`	`t.Run(tc.name, func(t *testing.T) {`
`137`	`137`	`ctx := context.Background()`
`138`	`138`	`for _, st := range allActorStatuses {`
`139`		`- err := tc.step.CheckPrerequisite(ctx, &PauseInput{ActorID: "id1"}, &PauseState{Actor: &ateapipb.Actor{Status: st}})`
	`139`	`+ err := tc.step.CheckPrerequisite(ctx, &PauseInput{ActorName: "id1"}, &PauseState{Actor: &ateapipb.Actor{Status: st}})`
`140`	`140`	`assertPrerequisiteResult(t, st, err, tc.allowed == nil \|\| tc.allowed[st])`
`141`	`141`	`}`
`142`	`142`	`})`
Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,7 @@ func (s AssignWorkerStep) CheckPrerequisite(ctx context.Context, input ResumeI`
`128`	`128`	`case ateapipb.Actor_STATUS_SUSPENDED, ateapipb.Actor_STATUS_PAUSED, ateapipb.Actor_STATUS_RESUMING:`
`129`	`129`	`return nil`
`130`	`130`	`default:`
`131`		`- return status.Errorf(codes.FailedPrecondition, "AssignWorkerStep prerequisite not met for Actor: %s (got: %v, want %s, %s or %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDED, ateapipb.Actor_STATUS_PAUSED, ateapipb.Actor_STATUS_RESUMING)`
	`131`	`+ return status.Errorf(codes.FailedPrecondition, "AssignWorkerStep prerequisite not met for Actor: %s (got: %v, want %s, %s or %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDED, ateapipb.Actor_STATUS_PAUSED, ateapipb.Actor_STATUS_RESUMING)`
`132`	`132`	`}`
`133`	`133`	`}`
`134`	`134`
`@@ -273,7 +273,7 @@ func (s CallAteletRestoreStep) IsComplete(ctx context.Context, input ResumeInp`
`273`	`273`	`}`
`274`	`274`	`func (s CallAteletRestoreStep) CheckPrerequisite(ctx context.Context, input ResumeInput, state *ResumeState) error {`
`275`	`275`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RESUMING {`
`276`		`- return status.Errorf(codes.FailedPrecondition, "CallAteletRestoreStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)`
	`276`	`+ return status.Errorf(codes.FailedPrecondition, "CallAteletRestoreStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)`
`277`	`277`	`}`
`278`	`278`	`return nil`
`279`	`279`	`}`
`@@ -383,7 +383,7 @@ func (s FinalizeRunningStep) IsComplete(ctx context.Context, input ResumeInput`
`383`	`383`	`}`
`384`	`384`	`func (s FinalizeRunningStep) CheckPrerequisite(ctx context.Context, input ResumeInput, state *ResumeState) error {`
`385`	`385`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RESUMING {`
`386`		`- return status.Errorf(codes.FailedPrecondition, "FinalizeRunningStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)`
	`386`	`+ return status.Errorf(codes.FailedPrecondition, "FinalizeRunningStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RESUMING)`
`387`	`387`	`}`
`388`	`388`	`return nil`
`389`	`389`	`}`
Original file line number	Diff line number	Diff line change
`@@ -288,7 +288,7 @@ func TestResumeSteps_CheckPrerequisite(t *testing.T) {`
`288`	`288`	`t.Run(tc.name, func(t *testing.T) {`
`289`	`289`	`ctx := context.Background()`
`290`	`290`	`for _, st := range allActorStatuses {`
`291`		`- err := tc.step.CheckPrerequisite(ctx, &ResumeInput{ActorID: "id1"}, &ResumeState{Actor: &ateapipb.Actor{Status: st}})`
	`291`	`+ err := tc.step.CheckPrerequisite(ctx, &ResumeInput{ActorName: "id1"}, &ResumeState{Actor: &ateapipb.Actor{Status: st}})`
`292`	`292`	`assertPrerequisiteResult(t, st, err, tc.allowed == nil \|\| tc.allowed[st])`
`293`	`293`	`}`
`294`	`294`	`})`
Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ func (s MarkSuspendingStep) IsComplete(ctx context.Context, input SuspendInput`
`87`	`87`	`}`
`88`	`88`	`func (s MarkSuspendingStep) CheckPrerequisite(ctx context.Context, input SuspendInput, state *SuspendState) error {`
`89`	`89`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_RUNNING {`
`90`		`- return status.Errorf(codes.FailedPrecondition, "MarkSuspendingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)`
	`90`	`+ return status.Errorf(codes.FailedPrecondition, "MarkSuspendingStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_RUNNING)`
`91`	`91`	`}`
`92`	`92`	`return nil`
`93`	`93`	`}`
`@@ -117,7 +117,7 @@ func (s CallAteletSuspendStep) IsComplete(ctx context.Context, input SuspendIn`
`117`	`117`	`}`
`118`	`118`	`func (s CallAteletSuspendStep) CheckPrerequisite(ctx context.Context, input SuspendInput, state *SuspendState) error {`
`119`	`119`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_SUSPENDING {`
`120`		`- return status.Errorf(codes.FailedPrecondition, "CallAteletSuspendStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)`
	`120`	`+ return status.Errorf(codes.FailedPrecondition, "CallAteletSuspendStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)`
`121`	`121`	`}`
`122`	`122`	`return nil`
`123`	`123`	`}`
`@@ -176,7 +176,7 @@ func (s FinalizeSuspendedStep) IsComplete(ctx context.Context, input SuspendIn`
`176`	`176`	`}`
`177`	`177`	`func (s FinalizeSuspendedStep) CheckPrerequisite(ctx context.Context, input SuspendInput, state *SuspendState) error {`
`178`	`178`	`if state.Actor.GetStatus() != ateapipb.Actor_STATUS_SUSPENDING {`
`179`		`- return status.Errorf(codes.FailedPrecondition, "FinalizeSuspendedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorID, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)`
	`179`	`+ return status.Errorf(codes.FailedPrecondition, "FinalizeSuspendedStep prerequisite not met for Actor: %s (got: %v, want %s)", input.ActorName, state.Actor.GetStatus(), ateapipb.Actor_STATUS_SUSPENDING)`
`180`	`180`	`}`
`181`	`181`	`return nil`
`182`	`182`	`}`
Original file line number	Diff line number	Diff line change
`@@ -137,7 +137,7 @@ func TestSuspendSteps_CheckPrerequisite(t *testing.T) {`
`137`	`137`	`t.Run(tc.name, func(t *testing.T) {`
`138`	`138`	`ctx := context.Background()`
`139`	`139`	`for _, st := range allActorStatuses {`
`140`		`- err := tc.step.CheckPrerequisite(ctx, &SuspendInput{ActorID: "id1"}, &SuspendState{Actor: &ateapipb.Actor{Status: st}})`
	`140`	`+ err := tc.step.CheckPrerequisite(ctx, &SuspendInput{ActorName: "id1"}, &SuspendState{Actor: &ateapipb.Actor{Status: st}})`
`141`	`141`	`assertPrerequisiteResult(t, st, err, tc.allowed == nil \|\| tc.allowed[st])`
`142`	`142`	`}`
`143`	`143`	`})`
Original file line number	Diff line number	Diff line change
`@@ -50,16 +50,15 @@ func newTestActorWorkflow(t *testing.T, st store.Interface, tmplNamespace, tmplN`
`50`	`50`	`func seedWorkflowActor(t testing.T, ctx context.Context, st store.Interface, atespace, id, tmplNamespace, tmplName string, actorStatus ateapipb.Actor_Status, opts ...func(ateapipb.Actor)) {`
`51`	`51`	`t.Helper()`
`52`	`52`	`actor := &ateapipb.Actor{`
`53`		`- ActorId: id,`
`54`		`- Atespace: atespace,`
	`53`	`+ Metadata: &ateapipb.ResourceMetadata{Name: id, Atespace: atespace},`
`55`	`54`	`Status: actorStatus,`
`56`	`55`	`ActorTemplateNamespace: tmplNamespace,`
`57`	`56`	`ActorTemplateName: tmplName,`
`58`	`57`	`}`
`59`	`58`	`for _, opt := range opts {`
`60`	`59`	`opt(actor)`
`61`	`60`	`}`
`62`		`- if err := st.CreateActor(ctx, actor); err != nil {`
	`61`	`+ if _, err := st.CreateActor(ctx, actor); err != nil {`
`63`	`62`	`t.Fatalf("seed actor: %v", err)`
`64`	`63`	`}`
`65`	`64`	`}`