CsanadT commited on
Commit
bb98c8a
1 Parent(s): 12f7dc4

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +9 -6
app.py CHANGED
@@ -30,28 +30,31 @@ today = datetime.date.today()
30
  city = "vienna"
31
  weekly_data = get_weather_data_weekly(city, today)
32
 
33
- progress_bar.progress(50)
34
-
35
  progress_bar.progress(60)
36
 
37
  st.write(36 * "-")
38
 
 
 
39
  mr = project.get_model_registry()
40
  model = mr.get_best_model("aqi_model", "rmse", "min")
41
  model_dir = model.download()
42
  model = joblib.load(model_dir + "/aqi_model.pkl")
43
 
 
 
44
  progress_bar.progress(80)
45
- st.sidebar.write("-" * 36)
46
 
 
47
 
48
  preds = model.predict(data_encoder(weekly_data)).astype(int)
49
  poll_level = get_aplevel(preds.T.reshape(-1, 1))
50
 
51
- next_week = [(today + timedelta(days=d)).strftime('%A') for d in range(1, 7)]
52
 
53
- df = pd.DataFrame(data=preds, index=["eg"], columns=[f"AQI Predictions for {next_day}" for next_day in next_week], dtype=int)
54
 
55
- st.sidebar.write(df)
56
  progress_bar.progress(100)
57
  st.button("Re-run")
 
30
  city = "vienna"
31
  weekly_data = get_weather_data_weekly(city, today)
32
 
33
+ fancy_header('\n Acquired data!')
 
34
  progress_bar.progress(60)
35
 
36
  st.write(36 * "-")
37
 
38
+ fancy_header('\n Loading the XGBoost model from the Hopsworks Model Registry')
39
+
40
  mr = project.get_model_registry()
41
  model = mr.get_best_model("aqi_model", "rmse", "min")
42
  model_dir = model.download()
43
  model = joblib.load(model_dir + "/aqi_model.pkl")
44
 
45
+ fancy_header('\n Model loaded. Let's make predictions!')
46
+
47
  progress_bar.progress(80)
 
48
 
49
+ st.sidebar.write("-" * 36)
50
 
51
  preds = model.predict(data_encoder(weekly_data)).astype(int)
52
  poll_level = get_aplevel(preds.T.reshape(-1, 1))
53
 
54
+ next_week = [[(today + timedelta(days=d)).strftime('%Y-%m-%d'),(today + timedelta(days=d)).strftime('%A')] for d in range(1, 7)]
55
 
56
+ df = pd.DataFrame(data=[preds, poll_level], index=["AQI", "Air pollution level"], columns=[f"AQI Predictions for {next_day}" for next_day in next_week])
57
 
58
+ st.write(df)
59
  progress_bar.progress(100)
60
  st.button("Re-run")