44
taskStore p.TaskStore,
45
logger log.Logger,
47
>
return &TaskQueueTaskSuite{
48
>
Assertions: require.New(t),
49
>
taskManager: p.NewTaskManager(
50
>
taskStore,
51
>
serialization.NewSerializer(),
52
>
),
53
>
logger: logger,
54
>
}
55
>
}
56
58
>
}
59
61
>
}
62
64
>
s.Assertions = require.New(s.T())
65
>
s.ctx, s.cancel = context.WithTimeout(context.Background(), 30*time.Second*debug.TimeoutMultiplier)
66
>
67
>
s.stickyTTL = time.Second * 10
68
>
s.taskTTL = time.Second * 16
69
>
s.namespaceID = uuid.New().String()
70
>
s.taskQueueName = uuid.New().String()
71
>
s.taskQueueType = enumspb.TaskQueueType(rand.Int31n(
72
>
int32(len(enumspb.TaskQueueType_name)) + 1),
73
>
)
74
>
}
75
77
>
s.cancel()
78
>
}
79
80
func (s *TaskQueueTaskSuite) TestCreateGet_Conflict() {