Skip to content

Commit 99382c5

Browse files
committed
improved logs
1 parent bc07575 commit 99382c5

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/lib/processSnapshot.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -667,17 +667,19 @@ export default async function processSnapshot(snapshot: Snapshot, ctx: Context):
667667
// Wait for pending requests to complete
668668
const checkPending = async () => {
669669
const startTime = Date.now();
670+
ctx.log.debug(`${pendingRequests.size} Pending requests before wait for ${snapshot.name}: ${Array.from(pendingRequests)}`);
670671
while (pendingRequests.size > 0) {
671672
const elapsedTime = Date.now() - startTime;
672673
if (elapsedTime >= MAX_WAIT_FOR_REQUEST_CALL) {
673674
ctx.log.debug(`Timeout reached (${MAX_WAIT_FOR_REQUEST_CALL/1000}s). Stopping wait for pending requests.`);
675+
ctx.log.debug(`${pendingRequests.size} Pending requests after wait for ${snapshot.name}: ${Array.from(pendingRequests)}`);
676+
674677
break;
675678
}
676-
ctx.log.debug(`Pending requests: ${Array.from(pendingRequests)}`);
677679
await new Promise(resolve => setTimeout(resolve, 1000));
678680
}
679681
if(pendingRequests.size === 0) {
680-
ctx.log.debug('No pending requests.');
682+
ctx.log.debug(`No pending requests for ${snapshot.name}.`);
681683
}
682684
};
683685

0 commit comments

Comments
 (0)