Skip to content

Commit 274fa65

Browse files
authored
surface errors
1 parent d0e0409 commit 274fa65

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

backend/redis/queue.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ var createGroupCmd = redis.NewScript(`
109109
end
110110
111111
if not exists then
112-
redis.pcall('XGROUP', 'CREATE', streamKey, groupName, '$', 'MKSTREAM')
112+
redis.call('XGROUP', 'CREATE', streamKey, groupName, '$', 'MKSTREAM')
113113
end
114114
115115
return true

0 commit comments

Comments
 (0)