import {workerThread} from "jstests/concurrency/fsm_libs/worker_thread.js";

async function shouldForwardErrorsFromAsyncRunCallback(conn) {
    const args = {
        host: conn.host,
        dbName: "test",
        tid: "thread0",
        clusterOptions: {sharded: false, replication: false},
        latch: new CountDownLatch(1),
        errorLatch: new CountDownLatch(1),
    };

    const res = await workerThread.main([], args, async function () {
        throw new Error("Thrown intentionally");
    });
    assert.eq(res.err, "Error: Thrown intentionally", "should forward errors thrown in async run callback");
}

const conn = MongoRunner.runMongod();
await shouldForwardErrorsFromAsyncRunCallback(conn);
MongoRunner.stopMongod(conn);