server/sources/datafeed.py
changeset 8068 72210779ff6d
parent 7995 9a9f35ef418c
child 8069 4341fb713b14
equal deleted inserted replaced
8067:3841d8793efb 8068:72210779ff6d
   270 
   270 
   271     def init_import_log(self, session, **kwargs):
   271     def init_import_log(self, session, **kwargs):
   272         dataimport = session.create_entity('CWDataImport', cw_import_of=self,
   272         dataimport = session.create_entity('CWDataImport', cw_import_of=self,
   273                                            start_timestamp=datetime.utcnow(),
   273                                            start_timestamp=datetime.utcnow(),
   274                                            **kwargs)
   274                                            **kwargs)
       
   275         dataimport.init()
   275         return dataimport
   276         return dataimport
   276 
   277 
   277 class DataFeedParser(AppObject):
   278 class DataFeedParser(AppObject):
   278     __registry__ = 'parsers'
   279     __registry__ = 'parsers'
   279 
   280