Browse Source

[spark] Get dummy Scala logs

Romain Rigaux 11 years ago
parent
commit
1e75866
2 changed files with 9 additions and 6 deletions
  1. 8 6
      apps/spark/src/spark/models.py
  2. 1 0
      apps/spark/static/js/spark.vm.js

+ 8 - 6
apps/spark/src/spark/models.py

@@ -218,7 +218,7 @@ class SparkApi():  # Pig, DBquery, Phoenix...
     return {'id': api.submit_statement(session['id'], snippet['statement']).split('cells/')[1]}
 
   def check_status(self, notebook, snippet):
-    return {'status': 'ready'}
+    return {'status': 'available'}
 
   def fetch_result(self, notebook, snippet, rows):
     api = get_spark_api(self.user)
@@ -229,12 +229,14 @@ class SparkApi():  # Pig, DBquery, Phoenix...
       
     return {
         'data': [data['output']],
-        'meta': [{
-          'name': column.name,
-          'type': column.type,
-          'comment': column.comment
-        } for column in []]
+        'meta': [{'name': 'Header', 'type': 'String', 'comment': ''}]
     }
 
   def cancel(self, notebook, snippet):
     pass
+
+  def get_log(self, snippet):
+    return 'Not available'
+  
+  def _progress(self, snippet, logs):  
+    return 50

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

@@ -143,6 +143,7 @@ var Snippet = function (notebook, snippet) {
     if (val){
       self.showGrid(false);
       self.showChart(false);
+      self.getLogs();
     }
   });
   self.size = ko.observable(typeof snippet.size != "undefined" && snippet.size != null ? snippet.size : 12).extend({ numeric: 0 });