this repo has no description
fix counters
+4
-4
+4
-4
src/stages/stage3.ts
+4
-4
src/stages/stage3.ts
···
183
183
);
184
184
185
185
context.successfulRequests++;
186
-
didsSuccessfulTotal.inc();
187
-
didsProcessedTotal.inc();
188
186
189
187
// eslint-disable-next-line @typescript-eslint/no-unsafe-argument
190
188
await processStream(res.data, did, context);
191
189
} catch (error) {
192
190
if (!(error as Error).message.includes('Request failed with status code 502')) {
193
-
console.error(`Error with DID ${did}: ${(error as Error).message}`);
191
+
console.error(`Error with DID ${did}: ${error as Error}`);
194
192
}
195
193
196
194
try {
···
273
271
if (status !== 'retry') {
274
272
await redis.set(`${did}:status`, 'completed');
275
273
context.successfulDids++;
276
-
didsProcessedTotal.inc();
274
+
didsSuccessfulTotal.inc();
277
275
278
276
if (context.successfulDids % SUCCESSFUL_DIDS_LOG_INTERVAL === 0) {
279
277
console.log(`Processed ${context.successfulDids} DIDs.`);
···
289
287
} catch (redisError: unknown) {
290
288
console.error(`Redis set error for DID ${did}: ${(redisError as Error).message}`);
291
289
}
290
+
291
+
didsProcessedTotal.inc();
292
292
293
293
throw err;
294
294
}