Function testGetAll

integration-tests/tasks_get_del_bucket.ts:60–82

()

}

async function testGetAll() {
    for (let i = 0; i < 55; i++) {
        await bucket.schedule({ executeAt: new Date(Date.now() + 1000000), key: "" + i });
        await anotherBucket.schedule({ executeAt: new Date(Date.now() + 1000000), key: "100" + i });
        await bucketPluginCustom.schedule({ executeAt: new Date(Date.now() + 1000000), key: "10000" + i });
    }

    const inNamespace = await countAll(bucket);
    assertExpected(55, inNamespace)

    const inPlugin = await countAll(bucketPluginCustom);
    assertExpected(55, inPlugin)

    const all = await countAll();
    // other scripts are running, so we we have no idea how many there is overall, but it should be atleast 200
    if (all < 110) {
        throw new Error(`${inNamespace} < 110`)
    }

    await bucket.deleteAll()
    await anotherBucket.deleteAll()
    await bucketPluginCustom.deleteAll()
}

async function countAll(bucket?: Tasks.TaskBucket): Promise<number> {
    let last = 0;