equal
deleted
inserted
replaced
57 |
57 |
58 def __call__(self): |
58 def __call__(self): |
59 def update_feeds(repo): |
59 def update_feeds(repo): |
60 # don't iter on repo.sources which doesn't include copy based |
60 # don't iter on repo.sources which doesn't include copy based |
61 # sources (the one we're looking for) |
61 # sources (the one we're looking for) |
62 # take a list to avoid iterating on a dictionary which size may |
62 # take a list to avoid iterating on a dictionary whose size may |
63 # change |
63 # change |
64 for source in list(repo.sources_by_eid.values()): |
64 for source in list(repo.sources_by_eid.values()): |
65 if (not source.copy_based_source |
65 if (not source.copy_based_source |
66 or not repo.config.source_enabled(source) |
66 or not repo.config.source_enabled(source) |
67 or not source.config['synchronize']): |
67 or not source.config['synchronize']): |
81 __regid__ = 'cw.looping-tasks.dataimports-cleanup' |
81 __regid__ = 'cw.looping-tasks.dataimports-cleanup' |
82 events = ('server_startup',) |
82 events = ('server_startup',) |
83 |
83 |
84 def __call__(self): |
84 def __call__(self): |
85 def expire_dataimports(repo=self.repo): |
85 def expire_dataimports(repo=self.repo): |
86 for source in repo.sources_by_eid.itervalues(): |
86 for uri, source in repo.sources_by_uri.iteritems(): |
87 if (not source.copy_based_source |
87 if (uri == 'system' |
88 or not repo.config.source_enabled(source)): |
88 or not repo.config.source_enabled(source)): |
89 continue |
89 continue |
90 session = repo.internal_session() |
90 session = repo.internal_session() |
91 try: |
91 try: |
92 mindate = datetime.now() - timedelta(seconds=source.config['logs-lifetime']) |
92 mindate = datetime.now() - timedelta(seconds=source.config['logs-lifetime']) |