equal
deleted
inserted
replaced
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 |