server/sources/datafeed.py
branchstable
changeset 7351 ed66f236715d
parent 7001 c53aa19640b2
child 7378 86a1ae289f05
child 7443 c10164464afc
--- a/server/sources/datafeed.py	Mon May 09 17:42:28 2011 +0200
+++ b/server/sources/datafeed.py	Tue May 10 14:07:14 2011 +0200
@@ -120,7 +120,7 @@
             return False
         return datetime.now() < (self.latest_retrieval + self.synchro_interval)
 
-    def pull_data(self, session, force=False):
+    def pull_data(self, session, force=False, raise_on_error=False):
         if not force and self.fresh():
             return {}
         if self.config['delete-entities']:
@@ -135,6 +135,8 @@
                 if parser.process(url):
                     error = True
             except IOError, exc:
+                if raise_on_error:
+                    raise
                 self.error('could not pull data while processing %s: %s',
                            url, exc)
                 error = True