Runtime Error: Loop is not running

Versions:

fsspec                        2023.6.0
s3fs                          2023.6.0

I'm trying to use a basic method .get, inside of a fast API route. Like this:

@app.post("/run_job")
async def run_job(payload: JobPayload):
    metadata = payload.metadata
    job_id, job_type, creds = metadata.job_id, metadata.job_type, metadata.s3_creds

    job_dir = get_job_dir(job_id)
    job_dir.mkdir()

    import asyncio

    s3 = S3FileSystem(
        key=creds.access_key,
        secret=creds.secret_key,
        client_kwargs={"endpoint_url": creds.endpoint, "region_name": creds.region},
        asynchronous=True,
        loop=asyncio.get_event_loop(),
    )
    session = await s3.set_session()
    await s3._get(some_value.rstrip('/') + "/", local_path, recursive=True)

    await session.close()

This does not work, but using aiobotocore directly does. What am I doing wrong?

Reproduce the shown FastAPI route with fsspec 2023.6.0 and s3fs 2023.6.0, then inspect the S3FileSystem asynchronous setup, set_session, and _get entry points. Done means identifying why the event loop is not running and documenting or validating a corrective change.