Remove testing changes

near · Mar 21, 2024 · 0bda419 · 0bda419
1 parent ee4aeec
commit 0bda419
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/runner/src/stream-handler/worker.ts b/runner/src/stream-handler/worker.ts
@@ -151,7 +151,7 @@ async function blockQueueConsumer (workerContext: WorkerContext, streamKey: stri
 
         const postRunSpan = tracer.startSpan('Delete redis message and shift queue', {}, context.active());
         parentPort?.postMessage({ type: WorkerMessageType.STATUS, data: { status: Status.RUNNING } });
-        // await workerContext.redisClient.deleteStreamMessage(streamKey, streamMessageId);
+        await workerContext.redisClient.deleteStreamMessage(streamKey, streamMessageId);
         await workerContext.queue.shift();
 
         METRICS.EXECUTION_DURATION.labels({ indexer: indexerName, type: workerContext.streamType }).observe(performance.now() - startTime);

diff --git a/runner/tsconfig.json b/runner/tsconfig.json
@@ -16,8 +16,8 @@
     "strictFunctionTypes": true,                      /* When assigning functions, check to ensure parameters and the return values are subtype-compatible. */
     "noImplicitThis": true,                           /* Enable error reporting when 'this' is given the type 'any'. */
     "alwaysStrict": true,                             /* Ensure 'use strict' is always emitted. */
-    "noUnusedLocals": false,                           /* Enable error reporting when local variables aren't read. */
-    "noUnusedParameters": false,                       /* Raise an error when a function parameter isn't read. */
+    "noUnusedLocals": true,                           /* Enable error reporting when local variables aren't read. */
+    "noUnusedParameters": true,                       /* Raise an error when a function parameter isn't read. */
     "skipLibCheck": true                                 /* Skip type checking all .d.ts files. */
   },
   "include": ["src"],