Do not connect to redis server in ensureGroup

This commit is contained in:
Apher 2026-07-16 21:05:17 +00:00
parent 527cd21f40
commit e41a75e743

View File

@ -16,8 +16,6 @@ redis.quit = async () => {
} }
redis.ensureGroup = async (stream, group) => { redis.ensureGroup = async (stream, group) => {
await redis.connect();
try { try {
await redis.client.xGroupCreate(stream, group, "0", {MKSTREAM: true}); await redis.client.xGroupCreate(stream, group, "0", {MKSTREAM: true});