@@ -150,23 +150,25 @@ def fill_gap(self, gap, period):
150150 series = self .memDB .series
151151 timegap = np .timedelta64 (gap , self .time_units [period ])
152152
153-
153+ #if gaps is not of type dataframe- put it in a dataframe
154+ #if not isinstance(gaps, pd.DataFrame
154155 for g in gaps .iterrows ():
155- print ("i am g[0]" , g [0 ])
156- e = g [1 ]#row["datetime"]
157- s = g [- 1 ]#row["prevdate"]
158- print ( " i am the start" , s )
159- print (" I am the end" , e )
160- s = s + timegap
161- # for each gap time period in the larger gap ( until datetime = prev value)
162- # while s != e:
163- # points.append(('-9999', None, s, series.begin_date_time_utc, s, None, None, u'nc', None, None, series.site_id, series.variable_id, series.method_id, series.source_id, series.quality_control_level_id))
164- # s= s + timegap
165-
166- #add a row points.append() [('-9999', None, datetime.datetime(2007, 9, 28, 0, 10), '-7', datetime.datetime(2007, 9, 28, 7, 10), None, None, u'nc', None, None, 1, 4, 2, 1, 0)
167- #('-9999', None, DATE, series.begin_date_time_utc, UTCDATE, None, None, u'nc', None, None, series.site_id, series.variable_id, series.method_id, series.source_id, series.quality_control_level_id
168-
156+ row = g [1 ]
157+ e = row .datetime
158+ s = row .dateprev
169159
160+ #prime the loop
161+ s = s + timegap
162+ # for each gap time period in the larger gap ( until datetime = prev value)
163+ while s < e :
164+ utc_offset = (series .begin_date_time - series .begin_date_time_utc ).total_seconds ()/ 3600
165+ points .append ((- 9999 , None , s , utc_offset , s , None , None , u'nc' , None , None , series .site_id , series .variable_id , series .method_id , series .source_id , series .quality_control_level_id ))
166+ #('-9999', None, DATE, series.begin_date_time_utc, UTCDATE, None, None, u'nc', None, None,
167+ # series.site_id, series.variable_id, series.method_id, series.source_id,
168+ # series.quality_control_level_id
169+
170+ s = s + timegap
171+ print points
170172 self .add_points (points )
171173
172174 time_units = {
0 commit comments