Skip to content

Commit

Permalink
fix: CLeanup local changes
Browse files Browse the repository at this point in the history
  • Loading branch information
darunrs committed Feb 3, 2024
1 parent 36ffd47 commit 11b80e8
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion runner/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ void (async function main () {
while (true) {
const streamKeys = await redisClient.getStreams();
streamKeys.forEach((streamKey) => {
if (executors.get(streamKey) === undefined && streamKey.includes('dataplatform.near/social_feed2')) {
if (executors.get(streamKey) === undefined) {
const streamHandler = new StreamHandler(streamKey);
executors.set(streamKey, streamHandler);
}
Expand Down
2 changes: 1 addition & 1 deletion runner/src/stream-handler/worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ async function blockQueueConsumer (workerContext: WorkerContext, streamKey: stri
}
METRICS.BLOCK_WAIT_DURATION.labels({ indexer: indexerName, type: workerContext.streamType }).observe(performance.now() - blockStartTime);
await indexer.runFunctions(block, functions, isHistorical, { provision: true });
// 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);
Expand Down
4 changes: 2 additions & 2 deletions runner/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -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"],
Expand Down

0 comments on commit 11b80e8

Please sign in to comment.