server/sources/datafeed.py
changeset 7444 9bb8f89fd31c
parent 7399 972ed1843bd8
parent 7443 c10164464afc
child 7446 6fba86efdd09
--- a/server/sources/datafeed.py	Thu May 26 08:57:15 2011 +0200
+++ b/server/sources/datafeed.py	Thu May 26 18:24:55 2011 +0200
@@ -124,7 +124,7 @@
     def fresh(self):
         if self.latest_retrieval is None:
             return False
-        return datetime.now() < (self.latest_retrieval + self.synchro_interval)
+        return datetime.utcnow() < (self.latest_retrieval + self.synchro_interval)
 
     def pull_data(self, session, force=False, raise_on_error=False):
         if not force and self.fresh():
@@ -156,7 +156,7 @@
             for etype, eids in byetype.iteritems():
                 session.execute('DELETE %s X WHERE X eid IN (%s)'
                                 % (etype, ','.join(eids)))
-        self.latest_retrieval = datetime.now()
+        self.latest_retrieval = datetime.utcnow()
         session.execute('SET X latest_retrieval %(date)s WHERE X eid %(x)s',
                         {'x': self.eid, 'date': self.latest_retrieval})
         return parser.stats