make fairing as a subpackage in kubeflow

kubeflow · Sep 2, 2019 · 2fc55d2 · 2fc55d2
1 parent cd8b460
commit 2fc55d2
Show file tree

Hide file tree

Showing 144 changed files with 311 additions and 281 deletions.
diff --git a/.github/ISSUE_TEMPLATE/bug_report.md b/.github/ISSUE_TEMPLATE/bug_report.md
@@ -19,7 +19,7 @@ about: Tell us about a problem you are experiencing
 
 **Environment:**
 
-- Fairing version: (use `python -c "import fairing; print(fairing.__version__)"`):
+- Fairing version: (use `python -c "import kubeflow; print(kubeflow.__version__)"`):
 - Kubeflow version: (version number can be found at the bottom left corner of the Kubeflow dashboard):
 - Minikube version:
 - Kubernetes version: (use `kubectl version`):

diff --git a/.travis.yml b/.travis.yml
@@ -9,5 +9,5 @@ install:
     - pip install --upgrade pytest
 # Command to run tests
 script:
-    - cd tests/unit
+    - cd tests/fairing/unit
     - pytest
diff --git a/Dockerfile b/Dockerfile
@@ -40,8 +40,8 @@ RUN pip install --user -r requirements.txt
 COPY --chown=jovyan:users integration/ipython_kernel_config.py /home/jovyan/.ipython/profile_default/ipython_kernel_config.py
 COPY --chown=jovyan:users containerregistry /home/jovyan/work/fairing/containerregistry
 
-COPY --chown=jovyan:users examples/notebook /home/jovyan/work/fairing/
-COPY --chown=jovyan:users fairing /home/jovyan/work/fairing/fairing
+COPY --chown=jovyan:users examples/fairing/notebook /home/jovyan/work/fairing/
+COPY --chown=jovyan:users kubeflow/fairing /home/jovyan/work/fairing/fairing
 
 
 
diff --git a/Dockerfile.test b/Dockerfile.test
@@ -17,8 +17,8 @@ ENV PATH=/builder/google-cloud-sdk/bin/:$PATH
 RUN pip install pytest pytest-cov pytest-xdist papermill
 # TODO: Find a better to run e2e tests without
 # adding a lot of reqs
-COPY examples/prediction/requirements.txt  examples/prediction/requirements.txt 
-RUN pip install -r examples/prediction/requirements.txt
+COPY examples/fairing/prediction/requirements.txt  examples/fairing/prediction/requirements.txt 
+RUN pip install -r examples/fairing/prediction/requirements.txt
 
 # Install dependencies
 COPY setup.py requirements.txt /opt/fairing/

diff --git a/cloudbuild.yaml b/cloudbuild.yaml
@@ -19,7 +19,7 @@ steps:
   entrypoint: 'bash'
   args: 
       - '-c'
-      - 'gcloud container clusters get-credentials kubeflow-ci-fairing --zone us-central1-a && pytest -n 8 -v --durations=10 --cov=fairing --ignore=tests/integration/azure/ tests/'
+      - 'gcloud container clusters get-credentials kubeflow-ci-fairing --zone us-central1-a && pytest -n 8 -v --durations=10 --cov=fairing --ignore=tests/fairing/integration/azure/ tests/'
 
 images: ['gcr.io/$PROJECT_ID/fairing-test:latest']
 timeout: 3600s

diff --git a/examples/distributed-training/main.py → ...ples/fairing/distributed-training/main.py b/examples/distributed-training/main.py → ...ples/fairing/distributed-training/main.py
@@ -227,7 +227,7 @@ def feed_dict(train):
 
 if __name__ == '__main__':
     if os.getenv('FAIRING_RUNTIME', None) is None:
-        import fairing
+        from kubeflow import fairing
         fairing.config.set_preprocessor('python', input_files=[__file__])
         fairing.config.set_builder(
             name='docker', registry='gcr.io/mrick-gcp', base_image='tensorflow/tensorflow')

diff --git a/...les/distributed-training/requirements.txt → ...ing/distributed-training/requirements.txt b/...les/distributed-training/requirements.txt → ...ing/distributed-training/requirements.txt
diff --git a/examples/gcp/hello-world-gpu-pytorch.py → ...es/fairing/gcp/hello-world-gpu-pytorch.py b/examples/gcp/hello-world-gpu-pytorch.py → ...es/fairing/gcp/hello-world-gpu-pytorch.py
@@ -17,7 +17,7 @@ def train():
     if os.getenv('FAIRING_RUNTIME', None) is not None:
         train()
     else:
-        import fairing
+        from kubeflow import fairing
         # Setting up google container repositories (GCR) for storing output containers
         # You can use any docker container registry istead of GCR
         GCP_PROJECT = fairing.cloud.gcp.guess_project_name()

diff --git a/examples/kfserving/main.py → examples/fairing/kfserving/main.py b/examples/kfserving/main.py → examples/fairing/kfserving/main.py
@@ -13,7 +13,7 @@
 # limitations under the License.
 
 
-import fairing
+from kubeflow import fairing
 
 if __name__ == '__main__':
     fairing.config.set_deployer(

diff --git a/examples/kubeflow-gke/main.py → examples/fairing/kubeflow-gke/main.py b/examples/kubeflow-gke/main.py → examples/fairing/kubeflow-gke/main.py
@@ -73,7 +73,7 @@ def train():
 
 if __name__ == '__main__':
     if os.getenv('FAIRING_RUNTIME', None) is None:
-        import fairing
+        from kubeflow import fairing
         fairing.config.set_preprocessor('python', input_files=[__file__])
         fairing.config.set_builder(
             'append', base_image='tensorflow/tensorflow:1.13.1-py3')

diff --git a/examples/kubeflow/main.py → examples/fairing/kubeflow/main.py b/examples/kubeflow/main.py → examples/fairing/kubeflow/main.py
@@ -74,7 +74,7 @@ def train(self, **kwargs): #pylint:disable=unused-argument
 
 if __name__ == '__main__':
     if os.getenv('FAIRING_RUNTIME', None) is None:
-        import fairing
+        from kubeflow import fairing
         fairing.config.set_preprocessor('python', input_files=[__file__])
         fairing.config.set_builder(name='docker', registry='<your-registry-name>',
                                    base_image='tensorflow/tensorflow:1.13.1-py3')

diff --git a/...les/kubernetes-in-cluster-builder/main.py → ...ing/kubernetes-in-cluster-builder/main.py b/...les/kubernetes-in-cluster-builder/main.py → ...ing/kubernetes-in-cluster-builder/main.py
@@ -73,7 +73,7 @@ def train(self):
 
 if __name__ == '__main__':
     if os.getenv('FAIRING_RUNTIME', None) is None:
-        import fairing
+        from kubeflow import fairing
         fairing.config.set_preprocessor('python', input_files=[__file__])
         fairing.config.set_builder(
             name='cluster', registry='<your-registry-here>')

diff --git a/...netes-in-cluster-builder/requirements.txt → ...netes-in-cluster-builder/requirements.txt b/...netes-in-cluster-builder/requirements.txt → ...netes-in-cluster-builder/requirements.txt
diff --git a/examples/kubernetes/main.py → examples/fairing/kubernetes/main.py b/examples/kubernetes/main.py → examples/fairing/kubernetes/main.py
@@ -72,7 +72,7 @@ def train():
 
 if __name__ == '__main__':
     if os.getenv('FAIRING_RUNTIME', None) is None:
-        import fairing
+        from kubeflow import fairing
         fairing.config.set_preprocessor('python', input_files=[__file__])
         fairing.config.set_builder('docker', registry='<your-registry-name>',
                                    base_image='tensorflow/tensorflow:1.13.1-py3')

diff --git a/examples/kubernetes/requirements.txt → examples/fairing/kubernetes/requirements.txt b/examples/kubernetes/requirements.txt → examples/fairing/kubernetes/requirements.txt
diff --git a/examples/lightgbm/Dockerfile → examples/fairing/lightgbm/Dockerfile b/examples/lightgbm/Dockerfile → examples/fairing/lightgbm/Dockerfile
diff --git a/.../distributed-training-data-parallel.ipynb → .../distributed-training-data-parallel.ipynb b/.../distributed-training-data-parallel.ipynb → .../distributed-training-data-parallel.ipynb
@@ -15,8 +15,8 @@
    "source": [
     "import os\n",
     "from time import gmtime, strftime\n",
-    "import fairing\n",
-    "from fairing.frameworks import lightgbm\n",
+    "from kubeflow import fairing\n",
+    "from kubeflow.fairing.frameworks import lightgbm\n",
     "\n",
     "# Setting up google container repositories (GCR) for storing output containers\n",
     "# You can use any docker container registry istead of GCR\n",

diff --git a/examples/lightgbm/distributed-training.ipynb → ...iring/lightgbm/distributed-training.ipynb b/examples/lightgbm/distributed-training.ipynb → ...iring/lightgbm/distributed-training.ipynb
@@ -15,8 +15,8 @@
    "source": [
     "import os\n",
     "from time import gmtime, strftime\n",
-    "import fairing\n",
-    "from fairing.frameworks import lightgbm\n",
+    "from kubeflow import fairing\n",
+    "from kubeflow.fairing.frameworks import lightgbm\n",
     "\n",
     "# Setting up google container repositories (GCR) for storing output containers\n",
     "# You can use any docker container registry istead of GCR\n",

diff --git a/examples/lightgbm/simple-training.ipynb → ...es/fairing/lightgbm/simple-training.ipynb b/examples/lightgbm/simple-training.ipynb → ...es/fairing/lightgbm/simple-training.ipynb
@@ -13,7 +13,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "import fairing\n",
+    "from kubeflow import fairing\n",
     "\n",
     "# Setting up google container repositories (GCR) for storing output containers\n",
     "# You can use any docker container registry istead of GCR\n",
@@ -54,8 +54,8 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "import fairing\n",
-    "from fairing.frameworks import lightgbm"
+    "from kubeflow import fairing\n",
+    "from kubeflow.fairing.frameworks import lightgbm"
    ]
   },
   {

diff --git a/examples/notebook/deploy-to-gcp.ipynb → ...ples/fairing/notebook/deploy-to-gcp.ipynb b/examples/notebook/deploy-to-gcp.ipynb → ...ples/fairing/notebook/deploy-to-gcp.ipynb
@@ -183,7 +183,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "from fairing.deployers.gcp.gcpserving import GCPServingDeployer\n",
+    "from kubeflow.fairing.deployers.gcp.gcpserving import GCPServingDeployer\n",
     "deployer = GCPServingDeployer()\n",
     "deployer.deploy(VERSION_DIR, MODEL_NAME, VERSION_NAME)"
    ]

diff --git a/examples/notebook/fairing-kubeflow-gke.ipynb → ...iring/notebook/fairing-kubeflow-gke.ipynb b/examples/notebook/fairing-kubeflow-gke.ipynb → ...iring/notebook/fairing-kubeflow-gke.ipynb
@@ -34,7 +34,7 @@
     "from tensorflow.examples.tutorials.mnist import input_data\n",
     "from tensorflow.examples.tutorials.mnist import mnist\n",
     "\n",
-    "import fairing\n",
+    "from kubeflow import fairing\n",
     "fairing.config.set_builder(name='append')\n",
     "\n",
     "INPUT_DATA_DIR = '/tmp/tensorflow/mnist/input_data/'\n",

diff --git a/examples/notebook/fairing-xgboost.ipynb → ...es/fairing/notebook/fairing-xgboost.ipynb b/examples/notebook/fairing-xgboost.ipynb → ...es/fairing/notebook/fairing-xgboost.ipynb
@@ -114,7 +114,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "import fairing\n",
+    "from kubeflow import fairing\n",
     "run_training_and_eval = fairing.config.fn(run_training_and_eval)\n",
     "run_training_and_eval()"
    ]

diff --git a/examples/notebook/hello-world.ipynb → examples/fairing/notebook/hello-world.ipynb b/examples/notebook/hello-world.ipynb → examples/fairing/notebook/hello-world.ipynb
@@ -7,7 +7,7 @@
    "outputs": [],
    "source": [
     "import os\n",
-    "import fairing"
+    "from kubeflow import fairing"
    ]
   },
   {

diff --git a/examples/prediction/Dockerfile → examples/fairing/prediction/Dockerfile b/examples/prediction/Dockerfile → examples/fairing/prediction/Dockerfile
diff --git a/examples/prediction/HousingServe.py → examples/fairing/prediction/HousingServe.py b/examples/prediction/HousingServe.py → examples/fairing/prediction/HousingServe.py
@@ -13,8 +13,8 @@
 # limitations under the License.
 
 import joblib
-import fairing
 import numpy as np
+from kubeflow import fairing
 
 MODEL_FILE = 'trained_ames_model.dat'
 

diff --git a/examples/prediction/HousingTrain.py → examples/fairing/prediction/HousingTrain.py b/examples/prediction/HousingTrain.py → examples/fairing/prediction/HousingTrain.py
diff --git a/examples/prediction/README.md → examples/fairing/prediction/README.md b/examples/prediction/README.md → examples/fairing/prediction/README.md
diff --git a/...diction/ames_dataset/data_description.txt → ...diction/ames_dataset/data_description.txt b/...diction/ames_dataset/data_description.txt → ...diction/ames_dataset/data_description.txt
diff --git a/...iction/ames_dataset/sample_submission.csv → ...iction/ames_dataset/sample_submission.csv b/...iction/ames_dataset/sample_submission.csv → ...iction/ames_dataset/sample_submission.csv
diff --git a/examples/prediction/ames_dataset/test.csv → .../fairing/prediction/ames_dataset/test.csv b/examples/prediction/ames_dataset/test.csv → .../fairing/prediction/ames_dataset/test.csv
diff --git a/examples/prediction/ames_dataset/train.csv → ...fairing/prediction/ames_dataset/train.csv b/examples/prediction/ames_dataset/train.csv → ...fairing/prediction/ames_dataset/train.csv
diff --git a/examples/prediction/requirements.txt → examples/fairing/prediction/requirements.txt b/examples/prediction/requirements.txt → examples/fairing/prediction/requirements.txt
diff --git a/examples/prediction/trained_ames_model.dat → ...fairing/prediction/trained_ames_model.dat b/examples/prediction/trained_ames_model.dat → ...fairing/prediction/trained_ames_model.dat
diff --git a/examples/prediction/xgboost-gkeop.ipynb → ...es/fairing/prediction/xgboost-gkeop.ipynb b/examples/prediction/xgboost-gkeop.ipynb → ...es/fairing/prediction/xgboost-gkeop.ipynb
@@ -218,7 +218,7 @@
    "outputs": [],
    "source": [
     "import os\n",
-    "import fairing\n",
+    "from kubeflow import fairing\n",
     "\n",
     "# Setting up google container repositories (GCR) for storing output containers\n",
     "# You can use any docker container registry istead of GCR\n",
@@ -245,11 +245,11 @@
    },
    "outputs": [],
    "source": [
-    "import fairing\n",
-    "from fairing.builders.cluster import gcs_context\n",
-    "from fairing.builders.cluster.cluster import ClusterBuilder\n",
-    "from fairing.deployers.tfjob.tfjob import TfJob\n",
-    "from fairing.preprocessors.function import FunctionPreProcessor\n",
+    "from kubeflow import fairing\n",
+    "from kubeflow.fairing.builders.cluster import gcs_context\n",
+    "from kubeflow.fairing.builders.cluster.cluster import ClusterBuilder\n",
+    "from kubeflow.fairing.deployers.tfjob.tfjob import TfJob\n",
+    "from kubeflow.fairing.preprocessors.function import FunctionPreProcessor\n",
     "\n",
     "preprocessor = FunctionPreProcessor(function_obj=HousingServe, input_files=['ames_dataset/train.csv', \"requirements.txt\"])\n",
     "builder = ClusterBuilder(registry=DOCKER_REGISTRY, base_image=BASE_IMAGE, preprocessor=preprocessor,\n",
@@ -280,12 +280,12 @@
    },
    "outputs": [],
    "source": [
-    "import fairing\n",
-    "from fairing.builders.cluster import gcs_context\n",
-    "from fairing.builders.cluster.cluster import ClusterBuilder\n",
-    "from fairing.deployers.job.job import Job\n",
-    "from fairing.deployers.serving.serving import Serving\n",
-    "from fairing.preprocessors.function import FunctionPreProcessor\n",
+    "from kubeflow import fairing\n",
+    "from kubeflow.fairing.builders.cluster import gcs_context\n",
+    "from kubeflow.fairing.builders.cluster.cluster import ClusterBuilder\n",
+    "from kubeflow.fairing.deployers.job.job import Job\n",
+    "from kubeflow.fairing.deployers.serving.serving import Serving\n",
+    "from kubeflow.fairing.preprocessors.function import FunctionPreProcessor\n",
     "\n",
     "preprocessor = FunctionPreProcessor(function_obj=HousingServe, input_files=['trained_ames_model.dat', \"requirements.txt\"])\n",
     "builder = ClusterBuilder(registry=DOCKER_REGISTRY, base_image=BASE_IMAGE, preprocessor=preprocessor,\n",

diff --git a/.../prediction/xgboost-high-level-apis.ipynb → .../prediction/xgboost-high-level-apis.ipynb b/.../prediction/xgboost-high-level-apis.ipynb → .../prediction/xgboost-high-level-apis.ipynb
@@ -220,7 +220,7 @@
    },
    "outputs": [],
    "source": [
-    "import fairing\n",
+    "from kubeflow import fairing\n",
     "\n",
     "# Default to using the GKE backend.\n",
     "FAIRING_BACKEND = 'KubeflowGKEBackend'\n",
@@ -252,13 +252,13 @@
     "    DOCKER_REGISTRY = 'gcr.io/{}/fairing-job'.format(GCP_PROJECT)\n",
     "    BuildContext = None\n",
     "if FAIRING_BACKEND == 'KubeflowAzureBackend':\n",
-    "    from fairing.builders.cluster.azurestorage_context import StorageContextSource\n",
+    "    from kubeflow.fairing.builders.cluster.azurestorage_context import StorageContextSource\n",
     "    BuildContext = StorageContextSource(\n",
     "        region=AZURE_REGION, resource_group_name=AZURE_RESOURCE_GROUP,\n",
     "        storage_account_name=AZURE_STORAGE_ACCOUNT\n",
     "    )\n",
     "\n",
-    "BackendClass = getattr(importlib.import_module('fairing.backends'), FAIRING_BACKEND)"
+    "BackendClass = getattr(importlib.import_module('kubeflow.fairing.backends'), FAIRING_BACKEND)"
    ]
   },
   {
@@ -278,7 +278,7 @@
    },
    "outputs": [],
    "source": [
-    "from fairing import TrainJob\n",
+    "from kubeflow.fairing import TrainJob\n",
     "train_job = TrainJob(HousingServe, input_files=['ames_dataset/train.csv', \"requirements.txt\"],\n",
     "                     docker_registry=DOCKER_REGISTRY,\n",
     "                     backend=BackendClass(build_context_source=BuildContext))\n",
@@ -302,7 +302,7 @@
    },
    "outputs": [],
    "source": [
-    "from fairing import PredictionEndpoint\n",
+    "from kubeflow.fairing import PredictionEndpoint\n",
     "endpoint = PredictionEndpoint(HousingServe, input_files=['trained_ames_model.dat', \"requirements.txt\"],\n",
     "                              docker_registry=DOCKER_REGISTRY,\n",
     "                              backend=BackendClass(build_context_source=BuildContext))\n",

diff --git a/...d-deploy-in-gcp-from-local-notebook.ipynb → ...d-deploy-in-gcp-from-local-notebook.ipynb b/...d-deploy-in-gcp-from-local-notebook.ipynb → ...d-deploy-in-gcp-from-local-notebook.ipynb
@@ -191,7 +191,7 @@
    "outputs": [],
    "source": [
     "import os\n",
-    "import fairing\n",
+    "from kubeflow import fairing\n",
     "\n",
     "# Setting up google container repositories (GCR) for storing output containers\n",
     "# You can use any docker container registry istead of GCR\n",

diff --git a/examples/pytorch/mnist/mnist.ipynb → examples/fairing/pytorch/mnist/mnist.ipynb b/examples/pytorch/mnist/mnist.ipynb → examples/fairing/pytorch/mnist/mnist.ipynb
@@ -223,8 +223,8 @@
    "outputs": [],
    "source": [
     "import os\n",
-    "import fairing\n",
-    "from fairing import TrainJob\n",
+    "from kubeflow import fairing\n",
+    "from kubeflow.fairing import TrainJob\n",
     "import sys\n",
     "\n",
     "# Setting up google container repositories (GCR) for storing output containers\n",
@@ -253,7 +253,7 @@
     "train_job = TrainJob(train_and_test,\n",
     "                     base_docker_image=BASE_IMAGE,\n",
     "                     docker_registry=DOCKER_REGISTRY,\n",
-    "                     backend= fairing.backends.KubeflowGK(),\n",
+    "                     backend= kubeflow.fairing.backends.KubeflowGK(),\n",
     "                     input_files=[\"requirements.txt\"])\n",
     "train_job.submit()"
    ]
@@ -274,7 +274,7 @@
     "train_job = TrainJob(lambda: train_and_test(epochs=100),\n",
     "                     base_docker_image=BASE_IMAGE,\n",
     "                     docker_registry=DOCKER_REGISTRY,\n",
-    "                     backend= fairing.backends.GCPManagedBackend(),\n",
+    "                     backend= kubeflow.fairing.backends.GCPManagedBackend(),\n",
     "                     input_files=[\"requirements.txt\"])\n",
     "train_job.submit()"
    ]

diff --git a/examples/pytorch/mnist/requirements.txt → ...es/fairing/pytorch/mnist/requirements.txt b/examples/pytorch/mnist/requirements.txt → ...es/fairing/pytorch/mnist/requirements.txt
diff --git a/examples/simple/main.py → examples/fairing/simple/main.py b/examples/simple/main.py → examples/fairing/simple/main.py
@@ -1,7 +1,7 @@
 import os
-import fairing
 import tensorflow as tf
 
+from kubeflow import fairing
 # Setting up google container repositories (GCR) for storing output containers
 # You can use any docker container registry istead of GCR
 GCP_PROJECT = fairing.cloud.gcp.guess_project_name()

diff --git a/examples/train_job_api/main.ipynb → examples/fairing/train_job_api/main.ipynb b/examples/train_job_api/main.ipynb → examples/fairing/train_job_api/main.ipynb
@@ -6,10 +6,10 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "import fairing\n",
-    "from fairing import TrainJob\n",
-    "from fairing.backends import KubeflowGKEBackend\n",
-    "from fairing.kubernetes.utils import get_resource_mutator"
+    "from kubeflow import fairing\n",
+    "from kubeflow.fairing import TrainJob\n",
+    "from kubeflow.fairing.backends import KubeflowGKEBackend\n",
+    "from kubeflow.fairing.kubernetes.utils import get_resource_mutator"
    ]
   },
   {

diff --git a/examples/train_job_api/train.ipynb → examples/fairing/train_job_api/train.ipynb b/examples/train_job_api/train.ipynb → examples/fairing/train_job_api/train.ipynb
diff --git a/kubeflow/__init__.py b/kubeflow/__init__.py
@@ -0,0 +1,20 @@
+# Copyright 2016 The Kubernetes Authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+__project__ = 'kubeflow'
+
+# TBD @jinchihe update the __version__ automatically.
+__version__ = "0.0.3"
+
+import kubeflow.fairing
diff --git a/fairing/__init__.py → kubeflow/fairing/__init__.py b/fairing/__init__.py → kubeflow/fairing/__init__.py
@@ -2,10 +2,6 @@
 from .ml_tasks.tasks import TrainJob, PredictionEndpoint
 
 if os.getenv('FAIRING_RUNTIME', None) is not None:
-    from fairing.runtime_config import config
+    from .runtime_config import config
 else:
-    from fairing.config import config
-
-name = "fairing"
-
-__version__ = "0.5.3"
+    from .config import config
diff --git a/fairing/backends/__init__.py → kubeflow/fairing/backends/__init__.py b/fairing/backends/__init__.py → kubeflow/fairing/backends/__init__.py