async def METHOD_NAME(self):
    connection_string = self.endpoint
    policy_id = self._dp_policy_id
    # [START get_distribution_policy_async]
    from azure.communication.jobrouter.aio import JobRouterAdministrationClient
    router_admin_client = JobRouterAdministrationClient.from_connection_string(conn_str = connection_string)
    async with router_admin_client:
        distribution_policy = await router_admin_client.METHOD_NAME(distribution_policy_id = policy_id)
        print(f"Successfully fetched distribution policy with id: {distribution_policy.id}")
    # [END get_distribution_policy_async]