Merge d5105e7 into fff1895

reana_commons/k8s/api_client.py

@@ -0,0 +1,38 @@
+# -*- coding: utf-8 -*-
+#
+# This file is part of REANA.
+# Copyright (C) 2018 CERN.
+#
+# REANA is free software; you can redistribute it and/or modify it
+# under the terms of the MIT License; see LICENSE file for more details.
+
+"""Kubernetes API Client."""
+
+from functools import partial
+
+from kubernetes import client
+from kubernetes import config as k8s_config
+from werkzeug.local import LocalProxy
+
+
+def create_api_client(api='BatchV1'):
+    """Create Kubernetes API client using config.
+
+    :param api: String which represents which Kubernetes API to spawn. By
+        default BatchV1.
+    :returns: Kubernetes python client object for a specific API i.e. BatchV1.
+    """
+    k8s_config.load_incluster_config()
+    api_configuration = client.Configuration()
+    api_configuration.verify_ssl = False
+    if api == 'CoreV1':
+        api_client = client.CoreV1Api()
+    else:
+        api_client = client.BatchV1Api()
+    return api_client
+
+
+current_k8s_batchv1_api_client = LocalProxy(create_api_client)
+
+current_k8s_corev1_api_client = LocalProxy(partial(create_api_client,
+                                                   api='CoreV1'))

reana_commons/version.py

@@ -14,4 +14,4 @@
 
 from __future__ import absolute_import, print_function
 
-__version__ = "0.5.0.dev20181210"
+__version__ = "0.5.0.dev20181213"

setup.py

@@ -37,6 +37,9 @@
         'sphinx-rtd-theme>=0.1.9',
     ],
     'tests': tests_require,
+    'kubernetes': [
+        'kubernetes>=6.0.0',
+    ],
 }
 
 extras_require['all'] = []
@@ -56,6 +59,7 @@
     'click>=7.0,<8.0',
     'jsonschema[format]>=2.6.0,<2.7',
     'kombu>=4.2.0,<5.0',
+    'Werkzeug==0.14.1',
 ]
 
 packages = find_packages()