equal
deleted
inserted
replaced
1 from logilab.common import tempattr |
1 from logilab.common import tempattr |
2 from cubicweb.devtools.testlib import CubicWebTC |
2 from cubicweb.devtools.testlib import CubicWebTC |
|
3 from cubicweb.server.sources import datafeed |
3 |
4 |
4 |
5 |
5 class SynchronizeSourceTC(CubicWebTC): |
6 class SynchronizeSourceTC(CubicWebTC): |
|
7 |
6 def test_synchronize_view(self): |
8 def test_synchronize_view(self): |
7 with self.admin_access.web_request(vid='cw.source-sync') as req: |
9 with self.admin_access.web_request(vid='cw.source-sync') as req: |
8 source = req.create_entity('CWSource', name=u'ext', type=u'datafeed', |
10 |
9 parser=u'cw.entityxml') |
11 class AParser(datafeed.DataFeedParser): |
10 req.cnx.commit() |
12 __regid__ = 'testparser' |
|
13 |
|
14 def process(self, url, raise_on_error=False): |
|
15 pass |
|
16 |
|
17 with self.temporary_appobjects(AParser): |
|
18 source = req.create_entity('CWSource', name=u'ext', type=u'datafeed', |
|
19 parser=u'cw.entityxml') |
|
20 req.cnx.commit() |
11 |
21 |
12 self.threads = 0 |
22 self.threads = 0 |
13 |
23 |
14 def threaded_task(func): |
24 def threaded_task(func): |
15 self.threads += 1 |
25 self.threads += 1 |