feedback

yaananth · cschleiden · web-flow · commit 2715fba142f6 · 2023-07-14T13:15:59.000-04:00
Co-authored-by: Christopher Schleiden &lt;cschleiden@live.de&gt;
diff --git a/backend/redis/queue.go b/backend/redis/queue.go
@@ -59,7 +59,7 @@ func newTaskQueue[T any](rdb redis.UniversalClient, tasktype string) (*taskQueue
 	}
 
 	// Create the consumer group
-	_, err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey, tq.groupName}).Result()
+	err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey, tq.groupName}).Err()
 	if err != nil {
 		return nil, fmt.Errorf("creating task queue: %w", err)
 	}

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ func newTaskQueue[T any](rdb redis.UniversalClient, tasktype string) (*taskQueue`
`59`	`59`	`}`
`60`	`60`
`61`	`61`	`// Create the consumer group`
`62`		`- _, err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey, tq.groupName}).Result()`
	`62`	`+ err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey, tq.groupName}).Err()`
`63`	`63`	`if err != nil {`
`64`	`64`	`return nil, fmt.Errorf("creating task queue: %w", err)`
`65`	`65`	`}`