from prefect.client.orchestration import get_client

async def create_or_update_task_concurrency_tags(tag_name: str, concurrency_limit: int):
    async with get_client() as client:
        try:
            response = await client.read_concurrency_limit_by_tag(tag_name)
        except Exception as err:
            print(type(err))



if __name__ == "__main__":
    import asyncio

    asyncio.run(create_or_update_task_concurrency_tags("TAG_DOESNT_EXIST", None))