updating gradio

app.py

@@ -2,19 +2,30 @@ import gradio as gr
 import pandas as pd
 import numpy as np
 import random
+import os 
+import hopsworks
 
 from datetime import datetime, timedelta
 now = datetime.now()
 
-df = pd.DataFrame({
-    'time': [now - timedelta(minutes=5*i) for i in range(25)],
-    'price': np.random.randint(100, 1000, 25),
-    'origin': [random.choice(["DFW", "DAL", "HOU"]) for _ in range(25)],
-    'destination': [random.choice(["JFK", "LGA", "EWR"]) for _ in range(25)],
-})
+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() 
+
+air_quality_fg = fs.get_feature_group(
+    name='air_quality',
+    version=1,
+)
+air_quality_df = air_quality_fg.read()
+air_quality_df
+
+print(air_quality_df.info())
+print(air_quality_df)
 
 with gr.Blocks() as demo:
-    gr.LinePlot(df, x="time", y="price")
-    gr.ScatterPlot(df, x="time", y="price", color="origin")
+    gr.Markdown("Helsingborg Air Quality Forecast")
+    gr.LinePlot(air_quality_df, x="date", y="pm25")
 
-demo.launch()
+demo.launch()   

app2.py

@@ -0,0 +1,6 @@
+import gradio as gr
+
+with gr.Blocks() as demo:
+    gr.Markdown("Helsingborg Air Quality Forecast")
+    
+demo.launch()

debug.ipynb

@@ -2,19 +2,246 @@
  "cells": [
   {
    "cell_type": "code",
-   "execution_count": null,
-   "metadata": {
-    "vscode": {
-     "languageId": "plaintext"
+   "execution_count": 1,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stderr",
+     "output_type": "stream",
+     "text": [
+      "/home/robert/Documents/scalable-ml/hbg-weather/.venv/lib/python3.12/site-packages/gradio_client/documentation.py:106: UserWarning: Could not get documentation group for <class 'gradio.mix.Parallel'>: No known documentation group for module 'gradio.mix'\n",
+      "  warnings.warn(f\"Could not get documentation group for {cls}: {exc}\")\n",
+      "/home/robert/Documents/scalable-ml/hbg-weather/.venv/lib/python3.12/site-packages/gradio_client/documentation.py:106: UserWarning: Could not get documentation group for <class 'gradio.mix.Series'>: No known documentation group for module 'gradio.mix'\n",
+      "  warnings.warn(f\"Could not get documentation group for {cls}: {exc}\")\n"
+     ]
     }
-   },
+   ],
+   "source": [
+    "import gradio as gr\n",
+    "import pandas as pd\n",
+    "import numpy as np\n",
+    "import random\n",
+    "import os \n",
+    "import hopsworks"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 2,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Connected. Call `.close()` to terminate connection gracefully.\n",
+      "\n",
+      "Logged in to project, explore it here https://c.app.hopsworks.ai:443/p/1160340\n",
+      "2024-11-19 17:58:26,633 WARNING: using legacy validation callback\n",
+      "Connected. Call `.close()` to terminate connection gracefully.\n",
+      "Finished: Reading data from Hopsworks, using Hopsworks Feature Query Service (2.16s) \n",
+      "<class 'pandas.core.frame.DataFrame'>\n",
+      "RangeIndex: 1589 entries, 0 to 1588\n",
+      "Data columns (total 6 columns):\n",
+      " #   Column   Non-Null Count  Dtype  \n",
+      "---  ------   --------------  -----  \n",
+      " 0   date     1589 non-null   object \n",
+      " 1   pm25     1589 non-null   float32\n",
+      " 2   country  1589 non-null   object \n",
+      " 3   city     1589 non-null   object \n",
+      " 4   street   1589 non-null   object \n",
+      " 5   url      1589 non-null   object \n",
+      "dtypes: float32(1), object(5)\n",
+      "memory usage: 68.4+ KB\n",
+      "None\n",
+      "         date  pm25 country         city          street  \\\n",
+      "0  2024-02-23  18.0  Sweden  Helsingborg  Drottninggatan   \n",
+      "1  2021-09-22  36.0  Sweden  Helsingborg  Drottninggatan   \n",
+      "2  2022-09-25  55.0  Sweden  Helsingborg  Drottninggatan   \n",
+      "3  2024-08-25  24.0  Sweden  Helsingborg  Drottninggatan   \n",
+      "4  2023-01-06  18.0  Sweden  Helsingborg  Drottninggatan   \n",
+      "\n",
+      "                                  url  \n",
+      "0  https://api.waqi.info/feed/@12519/  \n",
+      "1  https://api.waqi.info/feed/@12519/  \n",
+      "2  https://api.waqi.info/feed/@12519/  \n",
+      "3  https://api.waqi.info/feed/@12519/  \n",
+      "4  https://api.waqi.info/feed/@12519/  \n"
+     ]
+    }
+   ],
+   "source": [
+    "\n",
+    "from datetime import datetime, timedelta\n",
+    "now = datetime.now()\n",
+    "\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",
+    "\n",
+    "air_quality_fg = fs.get_feature_group(\n",
+    "    name='air_quality',\n",
+    "    version=1,\n",
+    ")\n",
+    "air_quality_df = air_quality_fg.read()\n",
+    "air_quality_df\n",
+    "\n",
+    "print(air_quality_df.info())\n",
+    "print(air_quality_df.head())"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 7,
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/html": [
+       "<div>\n",
+       "<style scoped>\n",
+       "    .dataframe tbody tr th:only-of-type {\n",
+       "        vertical-align: middle;\n",
+       "    }\n",
+       "\n",
+       "    .dataframe tbody tr th {\n",
+       "        vertical-align: top;\n",
+       "    }\n",
+       "\n",
+       "    .dataframe thead th {\n",
+       "        text-align: right;\n",
+       "    }\n",
+       "</style>\n",
+       "<table border=\"1\" class=\"dataframe\">\n",
+       "  <thead>\n",
+       "    <tr style=\"text-align: right;\">\n",
+       "      <th></th>\n",
+       "      <th>date</th>\n",
+       "      <th>pm25</th>\n",
+       "    </tr>\n",
+       "  </thead>\n",
+       "  <tbody>\n",
+       "    <tr>\n",
+       "      <th>0</th>\n",
+       "      <td>2024-02-23</td>\n",
+       "      <td>18.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>1</th>\n",
+       "      <td>2021-09-22</td>\n",
+       "      <td>36.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>2</th>\n",
+       "      <td>2022-09-25</td>\n",
+       "      <td>55.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>3</th>\n",
+       "      <td>2024-08-25</td>\n",
+       "      <td>24.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>4</th>\n",
+       "      <td>2023-01-06</td>\n",
+       "      <td>18.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>...</th>\n",
+       "      <td>...</td>\n",
+       "      <td>...</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>1584</th>\n",
+       "      <td>2022-11-26</td>\n",
+       "      <td>42.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>1585</th>\n",
+       "      <td>2021-02-27</td>\n",
+       "      <td>35.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>1586</th>\n",
+       "      <td>2021-10-26</td>\n",
+       "      <td>36.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>1587</th>\n",
+       "      <td>2022-05-12</td>\n",
+       "      <td>21.0</td>\n",
+       "    </tr>\n",
+       "    <tr>\n",
+       "      <th>1588</th>\n",
+       "      <td>2024-11-16</td>\n",
+       "      <td>34.0</td>\n",
+       "    </tr>\n",
+       "  </tbody>\n",
+       "</table>\n",
+       "<p>1589 rows × 2 columns</p>\n",
+       "</div>"
+      ],
+      "text/plain": [
+       "            date  pm25\n",
+       "0     2024-02-23  18.0\n",
+       "1     2021-09-22  36.0\n",
+       "2     2022-09-25  55.0\n",
+       "3     2024-08-25  24.0\n",
+       "4     2023-01-06  18.0\n",
+       "...          ...   ...\n",
+       "1584  2022-11-26  42.0\n",
+       "1585  2021-02-27  35.0\n",
+       "1586  2021-10-26  36.0\n",
+       "1587  2022-05-12  21.0\n",
+       "1588  2024-11-16  34.0\n",
+       "\n",
+       "[1589 rows x 2 columns]"
+      ]
+     },
+     "execution_count": 7,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "air_quality_df[['date', 'pm25']]"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
    "outputs": [],
-   "source": []
+   "source": [
+    "\n",
+    "with gr.Blocks() as demo:\n",
+    "    gr.Markdown(\"Helsingborg Air Quality Forecast\")\n",
+    "    gr.LinePlot(air_quality_df, x=\"time\", y=\"price\")\n",
+    "    gr.ScatterPlot(air_quality_df['pm25'], x=\"time\", y=\"price\", color=\"origin\")\n",
+    "\n",
+    "demo.launch()   "
+   ]
   }
  ],
  "metadata": {
+  "kernelspec": {
+   "display_name": ".venv",
+   "language": "python",
+   "name": "python3"
+  },
   "language_info": {
-   "name": "python"
+   "codemirror_mode": {
+    "name": "ipython",
+    "version": 3
+   },
+   "file_extension": ".py",
+   "mimetype": "text/x-python",
+   "name": "python",
+   "nbconvert_exporter": "python",
+   "pygments_lexer": "ipython3",
+   "version": "3.12.4"
   }
  },
  "nbformat": 4,

requirements-llm.txt

@@ -1,11 +0,0 @@
-# LLM libraries
-gradio==3.40.1
-getpass4==0.0.14.1
-
-transformers==4.38.2
-langchain==0.1.10
-bitsandbytes==0.42.0
-accelerate==0.27.2
-
-# OpenAI
-openai==1.14.3

scheduler.py

@@ -2,6 +2,6 @@ import modal
 
 app = modal.App('scheduler')
 
-@app.function(schedule=modal.Period(seconds=15))
+@app.function(schedule=modal.Period(minutes=1))
 def update():
     print('Updating...')