Add end_at parameter to latest data task

alphagov · Jan 26, 2015 · cb33dad · cb33dad
1 parent 7b03da1
commit cb33dad
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/backdrop/transformers/tasks/latest_dataset_value.py b/backdrop/transformers/tasks/latest_dataset_value.py
@@ -1,3 +1,5 @@
+import datetime
+import pytz
 import string
 
 from .util import encode_id
@@ -19,6 +21,7 @@ def get_read_params(transform_params, latest_timestamp):
         read_params['period'] = transform_params['period']
     else:
         read_params['start_at'] = latest_timestamp
+        read_params['end_at'] = datetime.datetime.now(pytz.UTC).replace(microsecond=0)
     read_params['sort_by'] = '_timestamp:descending'
     return read_params