server/sources/datafeed.py
changeset 7379 31adf834a8c6
parent 7378 86a1ae289f05
child 7385 29f050e39b09
equal deleted inserted replaced
7378:86a1ae289f05 7379:31adf834a8c6
   249 
   249 
   250     def process(self, url, partialcommit=True):
   250     def process(self, url, partialcommit=True):
   251         """IDataFeedParser main entry point"""
   251         """IDataFeedParser main entry point"""
   252         error = False
   252         error = False
   253         for args in self.parse(url):
   253         for args in self.parse(url):
   254             print args
       
   255             try:
   254             try:
   256                 self.process_item(*args)
   255                 self.process_item(*args)
   257                 if partialcommit:
   256                 if partialcommit:
   258                     # commit+set_pool instead of commit(reset_pool=False) to let
   257                     # commit+set_pool instead of commit(reset_pool=False) to let
   259                     # other a chance to get our pool
   258                     # other a chance to get our pool