async def METHOD_NAME(self):
    connection_string = self.endpoint
    policy_id = self._dp_policy_id
    # [START update_distribution_policy_async]
    from azure.communication.jobrouter.aio import JobRouterAdministrationClient
    from azure.communication.jobrouter import (
        DistributionPolicy,
        RoundRobinMode,
    )
    # set `connection_string` to an existing ACS endpoint
    router_admin_client = JobRouterAdministrationClient.from_connection_string(conn_str = connection_string)
    print("JobRouterAdministrationClient created successfully!")
    async with router_admin_client:
        updated_distribution_policy: DistributionPolicy = await router_admin_client.METHOD_NAME(
            distribution_policy_id = policy_id,
            mode = RoundRobinMode(
                min_concurrent_offers = 1,
                max_concurrent_offers = 1
            )
        )
        print(f"Distribution policy successfully update with new distribution mode")
    # [END update_distribution_policy_async]