File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
data-science-onramp/data-ingestion Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 40
40
"worker_config" : {"num_instances" : 6 , "machine_type_uri" : "n1-standard-8" },
41
41
"software_config" : {
42
42
"image_version" : CLUSTER_IMAGE ,
43
- "optional_components" : ["ANACONDA" ],
43
+ "optional_components" : [5 ],
44
44
},
45
45
},
46
46
}
58
58
def setup_and_teardown_cluster ():
59
59
# Create cluster using cluster client
60
60
cluster_client = dataproc .ClusterControllerClient (
61
- # client_options={"api_endpoint": f"{CLUSTER_REGION}-dataproc.googleapis.com:443"}
61
+ client_options = {"api_endpoint" : f"{ CLUSTER_REGION } -dataproc.googleapis.com:443" }
62
62
)
63
63
64
64
operation = cluster_client .create_cluster (
@@ -72,7 +72,7 @@ def setup_and_teardown_cluster():
72
72
73
73
# Delete cluster
74
74
operation = cluster_client .delete_cluster (
75
- project_id = PROJECT_ID , region = CLUSTER_REGION , name = DATAPROC_CLUSTER
75
+ project_id = PROJECT_ID , region = CLUSTER_REGION , cluster_name = DATAPROC_CLUSTER
76
76
)
77
77
operation .result ()
78
78
You can’t perform that action at this time.
0 commit comments