|
8 | 8 | commonpb "go.temporal.io/api/common/v1" |
9 | 9 | enumspb "go.temporal.io/api/enums/v1" |
10 | 10 | failurepb "go.temporal.io/api/failure/v1" |
11 | | - "go.temporal.io/api/taskqueue/v1" |
| 11 | + taskqueuepb "go.temporal.io/api/taskqueue/v1" |
12 | 12 | "go.temporal.io/api/workflowservice/v1" |
13 | 13 | "go.temporal.io/server/api/historyservice/v1" |
14 | 14 | "go.temporal.io/server/chasm" |
@@ -94,7 +94,7 @@ func TestTransitionScheduled(t *testing.T) { |
94 | 94 | ScheduleToStartTimeout: durationpb.New(tc.scheduleToStartTimeout), |
95 | 95 | StartToCloseTimeout: durationpb.New(defaultStartToCloseTimeout), |
96 | 96 | Status: activitypb.ACTIVITY_EXECUTION_STATUS_UNSPECIFIED, |
97 | | - TaskQueue: &taskqueue.TaskQueue{Name: "test-task-queue"}, |
| 97 | + TaskQueue: &taskqueuepb.TaskQueue{Name: "test-task-queue"}, |
98 | 98 | }, |
99 | 99 | RequestData: chasm.NewDataField(ctx, &activitypb.ActivityRequestData{ |
100 | 100 | Input: input, |
@@ -247,7 +247,7 @@ func TestTransitionRescheduled(t *testing.T) { |
247 | 247 | ScheduleToStartTimeout: durationpb.New(tc.scheduleToStartTimeout), |
248 | 248 | StartToCloseTimeout: durationpb.New(defaultStartToCloseTimeout), |
249 | 249 | Status: activitypb.ACTIVITY_EXECUTION_STATUS_STARTED, |
250 | | - TaskQueue: &taskqueue.TaskQueue{Name: "test-task-queue"}, |
| 250 | + TaskQueue: &taskqueuepb.TaskQueue{Name: "test-task-queue"}, |
251 | 251 | }, |
252 | 252 | Attempt: chasm.NewDataField(ctx, attemptState), |
253 | 253 | Outcome: chasm.NewDataField(ctx, outcome), |
@@ -406,7 +406,7 @@ func TestTransitionTimedout(t *testing.T) { |
406 | 406 | ScheduleToStartTimeout: durationpb.New(defaultScheduleToStartTimeout), |
407 | 407 | StartToCloseTimeout: durationpb.New(defaultStartToCloseTimeout), |
408 | 408 | Status: tc.startStatus, |
409 | | - TaskQueue: &taskqueue.TaskQueue{Name: "test-task-queue"}, |
| 409 | + TaskQueue: &taskqueuepb.TaskQueue{Name: "test-task-queue"}, |
410 | 410 | }, |
411 | 411 | Attempt: chasm.NewDataField(ctx, attemptState), |
412 | 412 | Outcome: chasm.NewDataField(ctx, outcome), |
@@ -496,7 +496,7 @@ func TestTransitionCompleted(t *testing.T) { |
496 | 496 | ScheduleToStartTimeout: durationpb.New(defaultScheduleToStartTimeout), |
497 | 497 | StartToCloseTimeout: durationpb.New(defaultStartToCloseTimeout), |
498 | 498 | Status: activitypb.ACTIVITY_EXECUTION_STATUS_STARTED, |
499 | | - TaskQueue: &taskqueue.TaskQueue{Name: "test-task-queue"}, |
| 499 | + TaskQueue: &taskqueuepb.TaskQueue{Name: "test-task-queue"}, |
500 | 500 | }, |
501 | 501 | Attempt: chasm.NewDataField(ctx, attemptState), |
502 | 502 | Outcome: chasm.NewDataField(ctx, outcome), |
@@ -571,7 +571,7 @@ func TestTransitionFailed(t *testing.T) { |
571 | 571 | ScheduleToStartTimeout: durationpb.New(defaultScheduleToStartTimeout), |
572 | 572 | StartToCloseTimeout: durationpb.New(defaultStartToCloseTimeout), |
573 | 573 | Status: activitypb.ACTIVITY_EXECUTION_STATUS_STARTED, |
574 | | - TaskQueue: &taskqueue.TaskQueue{Name: "test-task-queue"}, |
| 574 | + TaskQueue: &taskqueuepb.TaskQueue{Name: "test-task-queue"}, |
575 | 575 | }, |
576 | 576 | Attempt: chasm.NewDataField(ctx, attemptState), |
577 | 577 | LastHeartbeat: chasm.NewDataField(ctx, heartbeatState), |
@@ -733,7 +733,7 @@ func TestTransitionCanceled(t *testing.T) { |
733 | 733 | ScheduleToStartTimeout: durationpb.New(defaultScheduleToStartTimeout), |
734 | 734 | StartToCloseTimeout: durationpb.New(defaultStartToCloseTimeout), |
735 | 735 | Status: activitypb.ACTIVITY_EXECUTION_STATUS_CANCEL_REQUESTED, |
736 | | - TaskQueue: &taskqueue.TaskQueue{Name: "test-task-queue"}, |
| 736 | + TaskQueue: &taskqueuepb.TaskQueue{Name: "test-task-queue"}, |
737 | 737 | }, |
738 | 738 | Attempt: chasm.NewDataField(ctx, attemptState), |
739 | 739 | Outcome: chasm.NewDataField(ctx, outcome), |
|
0 commit comments