diff --git a/dataproc/dataproc_e2e_test.py b/dataproc/dataproc_e2e_test.py index b83b2b6de264..0a45d080122f 100644 --- a/dataproc/dataproc_e2e_test.py +++ b/dataproc/dataproc_e2e_test.py @@ -25,6 +25,7 @@ CLUSTER_NAME = 'testcluster3' ZONE = 'us-central1-b' + def test_e2e(): output = submit_job_to_cluster.main( PROJECT, ZONE, CLUSTER_NAME, BUCKET) diff --git a/dataproc/submit_job_to_cluster.py b/dataproc/submit_job_to_cluster.py index ab833f02fcb2..1815078202f3 100644 --- a/dataproc/submit_job_to_cluster.py +++ b/dataproc/submit_job_to_cluster.py @@ -82,7 +82,7 @@ def create_cluster(dataproc, project, zone, region, cluster_name): 'machineTypeUri': 'n1-standard-1' }, 'workerConfig': { - 'numInstances' : 2, + 'numInstances': 2, 'machineTypeUri': 'n1-standard-1' } }