async def METHOD_NAME(running_task_db: RunningTaskDb, instances: List[RunningTaskData]) -> None:
    await running_task_db.update_many(instances)
    not_done = list(filter(lambda x: not x.done, instances))
    assert not_done.sort() == [sub async for sub in running_task_db.all_running()].sort()