Ver Fonte

HUE-7728 [jb] Do not error in the SQL query browser when pointing to an old Impala

Avoid:
[10/Jan/2018 14:24:49 +0000] api2         ERROR    Error running <function job at 0x7f29de1c2410>
Traceback (most recent call last):
  File "/home/romain/projects/hue/apps/jobbrowser/src/jobbrowser/api2.py", line 38, in decorator
    return func(*args, **kwargs)
  File "/home/romain/projects/hue/apps/jobbrowser/src/jobbrowser/api2.py", line 73, in job
    response_app = get_api(request.user, interface).app(app_id)
  File "/home/romain/projects/hue/apps/jobbrowser/src/jobbrowser/apis/query_api.py", line 108, in app
    'text': 'id:' + appid
  File "/home/romain/projects/hue/apps/jobbrowser/src/jobbrowser/apis/query_api.py", line 76, in apps
    } for job in jobs_iter_filtered], key=lambda job: job.get('submitted'), reverse=True),
KeyError: 'resource_pool'
Romain Rigaux há 7 anos atrás
pai
commit
abf042168a
1 ficheiros alterados com 1 adições e 1 exclusões
  1. 1 1
      apps/jobbrowser/src/jobbrowser/apis/query_api.py

+ 1 - 1
apps/jobbrowser/src/jobbrowser/apis/query_api.py

@@ -64,7 +64,7 @@ class QueryApi(Api):
         'apiStatus': self._api_status(job['state']),
         'apiStatus': self._api_status(job['state']),
         'type': job['stmt_type'],
         'type': job['stmt_type'],
         'user': job['effective_user'],
         'user': job['effective_user'],
-        'queue': job['resource_pool'],
+        'queue': job.get('resource_pool'),
         'progress': job['progress'],
         'progress': job['progress'],
         'canWrite': job in jobs['in_flight_queries'],
         'canWrite': job in jobs['in_flight_queries'],
         'duration': self._time_in_ms_groups(re.search(r"\s*(([\d.]*)([a-z]*))(([\d.]*)([a-z]*))?(([\d.]*)([a-z]*))?", job['duration'], re.MULTILINE).groups()),
         'duration': self._time_in_ms_groups(re.search(r"\s*(([\d.]*)([a-z]*))(([\d.]*)([a-z]*))?(([\d.]*)([a-z]*))?", job['duration'], re.MULTILINE).groups()),