code:

import base64
from google.cloud import dataproc_v1
from google.cloud.dataproc_v1.gapic.transports import cluster_controller_grpc_transport

def hello_pubsub(event, context):
pubsub_message = base64.b64decode(event['data']).decode('utf-8')
print(pubsub_message)
print("inside function")
#region = "us-central1"
transport = cluster_controller_grpc_transport.ClusterControllerGrpcTransport(
address='us-central1-dataproc.googleapis.com:443')
client = dataproc_v1.ClusterControllerClient(transport)
#region = "us-central1"
print("Client value is", client)

Initialize request argument(s)

request = dataproc_v1.DeleteWorkflowTemplateRequest(
name="projects/xyz/regions/us-central1/workflowTemplates/template-123",
)

Make the request

if client.delete_workflow_template(request=request) == 1:
print("Client")
else:
print("Not deleted")

requirement.txt

google-cloud
google-cloud-dataproc
google-cloud-ndb
grpcio