equal
deleted
inserted
replaced
50 |
50 |
51 def __call__(self): |
51 def __call__(self): |
52 def update_feeds(repo): |
52 def update_feeds(repo): |
53 # take a list to avoid iterating on a dictionary whose size may |
53 # take a list to avoid iterating on a dictionary whose size may |
54 # change |
54 # change |
55 for uri, source in list(repo.sources_by_uri.iteritems()): |
55 for uri, source in list(repo.sources_by_uri.items()): |
56 if (uri == 'system' |
56 if (uri == 'system' |
57 or not repo.config.source_enabled(source) |
57 or not repo.config.source_enabled(source) |
58 or not source.config['synchronize']): |
58 or not source.config['synchronize']): |
59 continue |
59 continue |
60 with repo.internal_cnx() as cnx: |
60 with repo.internal_cnx() as cnx: |
70 __regid__ = 'cw.looping-tasks.dataimports-cleanup' |
70 __regid__ = 'cw.looping-tasks.dataimports-cleanup' |
71 events = ('server_startup',) |
71 events = ('server_startup',) |
72 |
72 |
73 def __call__(self): |
73 def __call__(self): |
74 def expire_dataimports(repo=self.repo): |
74 def expire_dataimports(repo=self.repo): |
75 for uri, source in repo.sources_by_uri.iteritems(): |
75 for uri, source in repo.sources_by_uri.items(): |
76 if (uri == 'system' |
76 if (uri == 'system' |
77 or not repo.config.source_enabled(source)): |
77 or not repo.config.source_enabled(source)): |
78 continue |
78 continue |
79 with repo.internal_cnx() as cnx: |
79 with repo.internal_cnx() as cnx: |
80 mindate = datetime.now() - timedelta(seconds=source.config['logs-lifetime']) |
80 mindate = datetime.now() - timedelta(seconds=source.config['logs-lifetime']) |