import asyncio


async def task1():
    await asyncio.create_subprocess_shell(
        "ls",
        # Any 2 pipes are required to reproduce
        stdin=asyncio.subprocess.PIPE,
        stdout=asyncio.subprocess.PIPE,
        stderr=asyncio.subprocess.PIPE,
    )
    print("task1 done")


async def task2():
    raise Exception("Task 2 failed")


async def main():
    # Either asyncio.gather, asyncio.TaskGroup, or asyncio.as_completed will cause the hang
    print("running gather")
    await asyncio.gather(task1(), task2())
    print("running tg")
    async with asyncio.TaskGroup() as tg:
        tg.create_task(task1())
        tg.create_task(task2())
    print("running as_completed")
    for result in asyncio.as_completed([task1(), task2()]):
        await result
    print("done")


if __name__ == "__main__":
    asyncio.run(main())