소스 검색

[spark] Fix polling the livy session status

Erick Tryzelaar 10 년 전
부모
커밋
e281ddc94a
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      apps/spark/src/spark/models.py

+ 1 - 1
apps/spark/src/spark/models.py

@@ -278,7 +278,7 @@ class SparkApi():
     status = api.get_session(response['id'])
     count = 0
 
-    while status['state'] == 'starting' or count < 60:
+    while status['state'] == 'starting' and count < 60:
       status = api.get_session(response['id'])
       count += 1
       time.sleep(1)