Skip to content

Commit

Permalink
Resolve lint errors
Browse files Browse the repository at this point in the history
  • Loading branch information
janbuchar committed Dec 19, 2024
1 parent 07b3717 commit 092d60c
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions packages/core/src/storages/request_provider.ts
Original file line number Diff line number Diff line change
Expand Up @@ -421,9 +421,9 @@ export abstract class RequestProvider implements IStorage {
});

this.inProgressRequestBatches.push(promise);
promise.finally(
() => (this.inProgressRequestBatches = this.inProgressRequestBatches.filter((it) => it !== promise)),
);
void promise.finally(() => {
this.inProgressRequestBatches = this.inProgressRequestBatches.filter((it) => it !== promise);
});

// If the user wants to wait for all the requests to be added, we wait for the promise to resolve for them
if (options.waitForAllRequestsToBeAdded) {
Expand Down
2 changes: 1 addition & 1 deletion packages/core/src/storages/request_queue_v2.ts
Original file line number Diff line number Diff line change
Expand Up @@ -294,7 +294,7 @@ export class RequestQueue extends RequestProvider {
// To retain the correct queue ordering, we rollback this head read.
if (hasPendingForefrontRequests && headData.hadMultipleClients) {
this.log.debug(`Skipping this read - forefront requests may not be fully consistent`);
await Promise.all(headData.items.map(({ id, uniqueKey }) => giveUpLock(id, uniqueKey)));
await Promise.all(headData.items.map(async ({ id, uniqueKey }) => giveUpLock(id, uniqueKey)));
}

for (const { id, uniqueKey } of headData.items) {
Expand Down

0 comments on commit 092d60c

Please sign in to comment.