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