Skip to content

Commit 79f02b6

Browse files
committed
fix(ci): drain telegram thread-binding persists before reset
1 parent ecc13c6 commit 79f02b6

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

extensions/telegram/src/thread-bindings.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -856,6 +856,10 @@ export async function resetTelegramThreadBindingsForTests() {
856856
for (const manager of getThreadBindingsState().managersByAccountId.values()) {
857857
manager.stop();
858858
}
859+
const pendingPersists = [...getThreadBindingsState().persistQueueByAccountId.values()];
860+
if (pendingPersists.length > 0) {
861+
await Promise.allSettled(pendingPersists);
862+
}
859863
getThreadBindingsState().persistQueueByAccountId.clear();
860864
getThreadBindingsState().managersByAccountId.clear();
861865
getThreadBindingsState().bindingsByAccountConversation.clear();

0 commit comments

Comments
 (0)