yml

debug.ipynb

@@ -2,7 +2,7 @@
  "cells": [
   {
    "cell_type": "code",
-   "execution_count": 5,
+   "execution_count": null,
    "metadata": {},
    "outputs": [
     {
@@ -37,7 +37,6 @@
     "\n",
     "api_key = os.getenv('HOPSWORKS_API_KEY')\n",
     "project_name = os.getenv('HOPSWORKS_PROJECT')\n",
-    "\n",
     "project = hopsworks.login(project=project_name, api_key_value=api_key)\n",
     "fs = project.get_feature_store() \n",
     "secrets = util.secrets_api(project.name)\n",

feature_pipeline.py

@@ -46,6 +46,9 @@ warnings.filterwarnings("ignore")
 # os.environ["HOPSWORKS_API_KEY"] = ""
 
 project = hopsworks.login()
+api_key = os.getenv('HOPSWORKS_API_KEY')
+project_name = os.getenv('HOPSWORKS_PROJECT')
+project = hopsworks.login(project=project_name, api_key_value=api_key)
 fs = project.get_feature_store() 
 secrets = util.secrets_api(project.name)
 

inference_pipeline.py

@@ -38,7 +38,9 @@ today
 
 # os.environ["HOPSWORKS_API_KEY"] = ""
 
-project = hopsworks.login()
+api_key = os.getenv('HOPSWORKS_API_KEY')
+project_name = os.getenv('HOPSWORKS_PROJECT')
+project = hopsworks.login(project=project_name, api_key_value=api_key)
 fs = project.get_feature_store() 
 
 secrets = util.secrets_api(project.name)

merge_df.py

@@ -14,9 +14,6 @@ os.environ['HOPSWORKS_API_KEY'] = os.getenv('HOPSWORKS_API_KEY')
 project = hopsworks.login()
 fs = project.get_feature_store() 
 
-project = hopsworks.login()
-fs = project.get_feature_store() 
-
 mr = project.get_model_registry()
 retrieved_model = mr.get_model(
     name="air_quality_xgboost_model",