from google.cloud.dataproc_v1 import ClusterControllerClient
client = ClusterControllerClient.from_service_account_file(
service_account_json_path,
client_options={'api_endpoint': f'{your_region}-dataproc.googleapis.com:443'})