Prepare for PR

near · Dec 19, 2023 · 7645a9d · 7645a9d
1 parent d03db02
commit 7645a9d
Showing 1 changed file with 1 addition and 5 deletions.
diff --git 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<string, StreamHandler>;
 
 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) {