From 7645a9dce82501b7f4a9146227ed64a64dfcd1cb Mon Sep 17 00:00:00 2001 From: Darun Seethammagari Date: Mon, 18 Dec 2023 19:09:21 -0800 Subject: [PATCH] Prepare for PR --- runner/src/index.ts | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/runner/src/index.ts b/runner/src/index.ts index 185e9455d..a4f0d4070 100644 --- a/runner/src/index.ts +++ b/runner/src/index.ts @@ -1,7 +1,6 @@ import { startServer as startMetricsServer } from './metrics'; import RedisClient from './redis-client'; import StreamHandler from './stream-handler'; -import startServer from './service/runner-server'; const STREAM_HANDLER_THROTTLE_MS = 500; @@ -14,14 +13,11 @@ startMetricsServer().catch((err) => { type StreamHandlers = Record; void (async function main () { - startServer(); - try { const streamHandlers: StreamHandlers = {}; while (true) { - // const streamKeys = await redisClient.getStreams(); - const streamKeys: string[] = []; + const streamKeys = await redisClient.getStreams(); streamKeys.forEach((streamKey) => { if (streamHandlers[streamKey] !== undefined) {