async def METHOD_NAME(self, resource_group_name, server_name, database_name,
                                                 subscription_id: str):
    try:
        client = self.get_client(subscription_id)
        return await run_concurrently(
            lambda: client.database_threat_detection_policies.get(resource_group_name, server_name, database_name,
                                                                  'default')
        )
    except Exception as e:
        print_exception(f'Failed to retrieve database threat detection policies: {e}')
        return []