server/sources/datafeed.py
changeset 7447 d5705c9bbe82
parent 7446 6fba86efdd09
child 7456 c54038622fc9
equal deleted inserted replaced
7446:6fba86efdd09 7447:d5705c9bbe82
   267 
   267 
   268 class DataFeedXMLParser(DataFeedParser):
   268 class DataFeedXMLParser(DataFeedParser):
   269 
   269 
   270     def process(self, url, raise_on_error=False, partialcommit=True):
   270     def process(self, url, raise_on_error=False, partialcommit=True):
   271         """IDataFeedParser main entry point"""
   271         """IDataFeedParser main entry point"""
       
   272         try:
       
   273             parsed = self.parse(url)
       
   274         except Exception, ex:
       
   275             self.source.error(ex)
       
   276             return True
   272         error = False
   277         error = False
   273         for args in self.parse(url):
   278         for args in parsed:
   274             try:
   279             try:
   275                 self.process_item(*args)
   280                 self.process_item(*args)
   276                 if partialcommit:
   281                 if partialcommit:
   277                     # commit+set_cnxset instead of commit(free_cnxset=False) to let
   282                     # commit+set_cnxset instead of commit(free_cnxset=False) to let
   278                     # other a chance to get our connections set
   283                     # other a chance to get our connections set