akshayballal commited on
Commit
10e6dfd
1 Parent(s): 4a389dc

Refactor RTUPipeline.py to remove commented out code and unused variables

Browse files
Files changed (1) hide show
  1. src/rtu/RTUPipeline.py +0 -47
src/rtu/RTUPipeline.py CHANGED
@@ -40,15 +40,6 @@ class RTUPipeline:
40
  "rtu_002_ma_temp",
41
  "rtu_002_sf_vfd_spd_fbk_tn",
42
  "rtu_002_rf_vfd_spd_fbk_tn",
43
- # "rtu_004_sat_sp_tn",
44
- # "rtu_003_sat_sp_tn",
45
- # "rtu_001_sat_sp_tn",
46
- # "rtu_002_sat_sp_tn",
47
- # "air_temp_set_1",
48
- # "air_temp_set_2",
49
- # "dew_point_temperature_set_1d",
50
- # "relative_humidity_set_1",
51
- # "solar_radiation_set_1",
52
  ]
53
 
54
  self.input_col_names = [
@@ -86,44 +77,6 @@ class RTUPipeline:
86
  payload = json.loads(message.payload.decode())
87
 
88
  len_df = len(self.df)
89
- # self.df.loc[len_df] = {'hp_hws_temp':payload['hp_hws_temp'],
90
- # 'rtu_003_sa_temp':payload['rtu_003_sa_temp'],
91
- # 'rtu_003_oadmpr_pct': payload["rtu_003_oadmpr_pct"],
92
- # 'rtu_003_ra_temp':payload["rtu_003_ra_temp"],
93
- # 'rtu_003_oa_temp': payload["rtu_003_oa_temp"],
94
- # 'rtu_003_ma_temp': payload["rtu_003_ma_temp"],
95
- # 'rtu_003_sf_vfd_spd_fbk_tn': payload["rtu_003_sf_vfd_spd_fbk_tn"],
96
- # 'rtu_003_rf_vfd_spd_fbk_tn':payload["rtu_003_rf_vfd_spd_fbk_tn"],
97
- # 'rtu_004_sa_temp':payload["rtu_004_sa_temp"],
98
- # 'rtu_004_oadmpr_pct':payload["rtu_004_oadmpr_pct"],
99
- # 'rtu_004_ra_temp':payload["rtu_004_ra_temp"],
100
- # 'rtu_004_oa_temp':payload["rtu_004_oa_temp"],
101
- # 'rtu_004_ma_temp':payload["rtu_004_ma_temp"],
102
- # 'rtu_004_sf_vfd_spd_fbk_tn':payload["rtu_004_sf_vfd_spd_fbk_tn"],
103
- # 'rtu_004_rf_vfd_spd_fbk_tn':payload["rtu_004_rf_vfd_spd_fbk_tn"],
104
- # 'rtu_001_sa_temp':payload["rtu_001_sa_temp"],
105
- # 'rtu_001_oadmpr_pct': payload["rtu_001_oadmpr_pct"],
106
- # 'rtu_001_ra_temp':payload["rtu_001_ra_temp"],
107
- # 'rtu_001_oa_temp': payload["rtu_001_oa_temp"],
108
- # 'rtu_001_ma_temp': payload["rtu_001_ma_temp"],
109
- # 'rtu_001_sf_vfd_spd_fbk_tn': payload["rtu_001_sf_vfd_spd_fbk_tn"],
110
- # 'rtu_001_rf_vfd_spd_fbk_tn':payload["rtu_001_rf_vfd_spd_fbk_tn"],
111
- # 'rtu_002_sa_temp':payload["rtu_002_sa_temp"],
112
- # 'rtu_002_oadmpr_pct':payload["rtu_002_oadmpr_pct"],
113
- # 'rtu_002_ra_temp':payload["rtu_002_ra_temp"],
114
- # 'rtu_002_oa_temp':payload["rtu_002_oa_temp"],
115
- # 'rtu_002_ma_temp':payload["rtu_002_ma_temp"],
116
- # 'rtu_002_sf_vfd_spd_fbk_tn':payload["rtu_002_sf_vfd_spd_fbk_tn"],
117
- # 'rtu_002_rf_vfd_spd_fbk_tn':payload["rtu_002_rf_vfd_spd_fbk_tn"],
118
- # 'rtu_004_sat_sp_tn':payload["rtu_004_sat_sp_tn"],
119
- # 'rtu_003_sat_sp_tn' :payload["rtu_003_sat_sp_tn"],
120
- # 'rtu_001_sat_sp_tn':payload["rtu_001_sat_sp_tn"],
121
- # 'rtu_002_sat_sp_tn':payload["rtu_002_sat_sp_tn"],
122
- # 'air_temp_set_1':payload["air_temp_set_1"],
123
- # 'air_temp_set_2':payload["air_temp_set_2"],
124
- # 'dew_point_temperature_set_1d':payload["dew_point_temperature_set_1d"],
125
- # 'relative_humidity_set_1':payload["relative_humidity_set_1"],
126
- # 'solar_radiation_set_1':payload["solar_radiation_set_1"]}
127
 
128
  k = {}
129
  for col in self.column_names:
 
40
  "rtu_002_ma_temp",
41
  "rtu_002_sf_vfd_spd_fbk_tn",
42
  "rtu_002_rf_vfd_spd_fbk_tn",
 
 
 
 
 
 
 
 
 
43
  ]
44
 
45
  self.input_col_names = [
 
77
  payload = json.loads(message.payload.decode())
78
 
79
  len_df = len(self.df)
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
80
 
81
  k = {}
82
  for col in self.column_names: