Always enqueue the aggregated task in the same queue

This commit is contained in:
Ken Hibino
2022-04-07 06:19:04 -07:00
parent 829f64fd38
commit 39718f8bea
2 changed files with 6 additions and 2 deletions

View File

@@ -160,7 +160,7 @@ func (a *aggregator) aggregate(t time.Time) {
}
aggregatedTask := a.ga.Aggregate(gname, tasks)
ctx, cancel := context.WithDeadline(context.Background(), deadline)
if _, err := a.client.EnqueueContext(ctx, aggregatedTask); err != nil {
if _, err := a.client.EnqueueContext(ctx, aggregatedTask, Queue(qname)); err != nil {
a.logger.Errorf("Failed to enqueue aggregated task (queue=%q, group=%q, setID=%q): %v",
qname, gname, aggregationSetID, err)
cancel()