Infra
/
lemur
5
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Minor changes for code review suggestions.

This commit is contained in:
Wesley Hartford 2018-12-18 22:24:48 -05:00
parent 060c78fd91
commit e7313da03e
1 changed files with 5 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
lemur/plugins/lemur_kubernetes/plugin.py
View File

@ -35,13 +35,7 @@ def ensure_resource(k8s_api, k8s_base_uri, namespace, kind, name, data):
if 200 <= create_resp.status_code <= 299: if 200 <= create_resp.status_code <= 299:
return None return None
elif create_resp.json().get('reason', '') != 'AlreadyExists':
else:
json = create_resp.json()
if 'reason' in json:
if json['reason'] != 'AlreadyExists':
return create_resp.content
else:
return create_resp.content return create_resp.content
url = _resolve_uri(k8s_base_uri, namespace, kind, name) url = _resolve_uri(k8s_base_uri, namespace, kind, name)
@ -53,7 +47,7 @@ def ensure_resource(k8s_api, k8s_base_uri, namespace, kind, name, data):
if not 200 <= update_resp.status_code <= 299: if not 200 <= update_resp.status_code <= 299:
return update_resp.content return update_resp.content
return None return
def _resolve_ns(k8s_base_uri, namespace, api_ver=DEFAULT_API_VERSION,): def _resolve_ns(k8s_base_uri, namespace, api_ver=DEFAULT_API_VERSION,):
@ -152,8 +146,8 @@ class KubernetesDestinationPlugin(DestinationPlugin):
} }
}) })
except Exception as e: except Exception as e:
current_app.logger.exception("Exception in upload") current_app.logger.exception("Exception in upload: {}".format(e), exc_info=True)
raise e raise
if err is not None: if err is not None:
current_app.logger.debug("Error deploying resource: %s", err) current_app.logger.debug("Error deploying resource: %s", err)