Merge pull request #8 from oli-hall/fix-blocking-create

Fix broken method calls
oli-hall · Nov 16, 2017 · 285a8e7 · 285a8e7
2 parents 2d501da + 0c28d02
commit 285a8e7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pydataproc/dataproc.py b/pydataproc/dataproc.py
@@ -162,12 +162,12 @@ def create_cluster(self, cluster_name, num_masters=1, num_workers=2,
             return result
 
 
-        is_running = self.dataproc.is_running(cluster_name)
+        is_running = self.is_running(cluster_name)
         log.info("Waiting for cluster to be ready...")
         log.warn("N.B. This may get stuck if the cluster never reaches a RUNNING state")
         while not is_running:
             time.sleep(5)
-            is_running = self.dataproc.is_running(cluster_name)
+            is_running = self.is_running(cluster_name)
 
         return self.cluster_info(cluster_name)