diff --git a/client.go b/client.go index 34aafd5..248b452 100644 --- a/client.go +++ b/client.go @@ -375,6 +375,7 @@ func (c *Client) EnqueueContext(ctx context.Context, task *Task, opts ...Option) Deadline: deadline.Unix(), Timeout: int64(timeout.Seconds()), UniqueKey: uniqueKey, + GroupKey: opt.groupKey, Retention: int64(opt.retention.Seconds()), } now := time.Now() diff --git a/client_test.go b/client_test.go index 06cfec5..d305d76 100644 --- a/client_test.go +++ b/client_test.go @@ -528,6 +528,7 @@ func TestClientEnqueueWithGroupOption(t *testing.T) { Queue: "default", Timeout: int64(defaultTimeout.Seconds()), Deadline: noDeadline.Unix(), + GroupKey: "mygroup", }, Score: now.Unix(), }, @@ -576,6 +577,7 @@ func TestClientEnqueueWithGroupOption(t *testing.T) { Queue: "default", Timeout: int64(defaultTimeout.Seconds()), Deadline: noDeadline.Unix(), + GroupKey: "mygroup", }, Score: now.Add(30 * time.Minute).Unix(), },