Change influxdb tasks to be task.every range

metobscommon/influxdb.py

@@ -148,7 +148,6 @@ def create_tasks(args):
 
 
 # Assume that data coming from realtime sources are no more than 1 minute late
-# XXX: Do I need to get 2x the interal of data?
 # XXX: Do I need to do anything about per-site/inst pair or per-symbol?
 AGGREGATE_FLUX_TASK_FORMAT = """
 option task = {{
@@ -158,7 +157,7 @@ option task = {{
 }}
 
 from(bucket: "{raw_bucket}")
-    |> range(start: -(task.every * 2))
+    |> range(start: -task.every)
     |> filter(fn: (r) => r["_measurement"] == "metobs")
     |> aggregateWindow(every: {interval}, fn: mean)
     |> set(key: "_measurement", value: "metobs_{interval}")