fix: gracefully remove consumer from redis on sigterm (#9252)

* gracefully remove consumer from redis on sigterm Signed-off-by: Matt Krick <matt.krick@gmail.com> * fix: gracefully remove consumer from redis on sigterm Signed-off-by: Matt Krick <matt.krick@gmail.com> --------- Signed-off-by: Matt Krick <matt.krick@gmail.com>
ParabolInc · Dec 7, 2023 · fd273bb · fd273bb
1 parent b4821d2
commit fd273bb
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/packages/gql-executor/gqlExecutor.ts b/packages/gql-executor/gqlExecutor.ts
@@ -27,6 +27,17 @@ const run = async () => {
   const subscriber = new RedisInstance('gql_sub')
   const executorChannel = GQLExecutorChannelId.join(SERVER_ID)
 
+  // on shutdown, remove consumer from the group
+  process.on('SIGTERM', async () => {
+    await publisher.xgroup(
+      'DELCONSUMER',
+      ServerChannel.GQL_EXECUTOR_STREAM,
+      ServerChannel.GQL_EXECUTOR_CONSUMER_GROUP,
+      executorChannel
+    )
+    process.exit()
+  })
+
   // subscribe to direct messages
   const onMessage = async (_channel: string, message: string) => {
     const {jobId, socketServerId, request} = JSON.parse(message) as PubSubPromiseMessage