Эх сурвалжийг харах

[oozie] Check snippet job status correctly

Romain Rigaux 11 жил өмнө
parent
commit
b024468

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

@@ -83,7 +83,7 @@ class HS2Api():
     snippet['result']['handle']['secret'], snippet['result']['handle']['guid'] = HiveServerQueryHandle.get_decoded(snippet['result']['handle']['secret'], snippet['result']['handle']['guid'])
     handle = HiveServerQueryHandle(**snippet['result']['handle'])
     status =  db.get_state(handle)
-    return {'query_status': 'running' if status in (QueryHistory.STATE.running.index, QueryHistory.STATE.submitted.index) else 'finished'}
+    return {'status': 'running' if status.index in (QueryHistory.STATE.running.index, QueryHistory.STATE.submitted.index) else 'finished'}
 
   def fetch_result(self, notebook, snippet):
     db = dbms.get(self.user)

+ 1 - 1
apps/spark/static/js/spark.vm.js

@@ -91,7 +91,7 @@ var Snippet = function (notebook, snippet) {
        snippet: ko.mapping.toJSON(self)
 	  }, function (data) {
 	    if (data.status == 0) {
-          self.status(data.query_status);
+          self.status(data.query_status.status);
             
           if (self.status() == 'running') {
             setTimeout(self.checkStatus, 1000);