equal
deleted
inserted
replaced
33 def process(self, url, raise_on_error=False): |
33 def process(self, url, raise_on_error=False): |
34 pass |
34 pass |
35 |
35 |
36 with self.temporary_appobjects(AParser): |
36 with self.temporary_appobjects(AParser): |
37 source = req.create_entity('CWSource', name=u'ext', type=u'datafeed', |
37 source = req.create_entity('CWSource', name=u'ext', type=u'datafeed', |
38 parser=u'cw.entityxml') |
38 parser=u'cw.entityxml', url=u'whatever') |
39 req.cnx.commit() |
39 req.cnx.commit() |
40 |
40 |
41 self.threads = 0 |
41 self.threads = 0 |
42 |
42 |
43 def threaded_task(func): |
43 def threaded_task(func): |