equal
deleted
inserted
replaced
75 for uri, source in repo.sources_by_uri.items(): |
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.utcnow() - timedelta(seconds=source.config['logs-lifetime']) |
81 cnx.execute('DELETE CWDataImport X WHERE X start_timestamp < %(time)s', |
81 cnx.execute('DELETE CWDataImport X WHERE X start_timestamp < %(time)s', |
82 {'time': mindate}) |
82 {'time': mindate}) |
83 cnx.commit() |
83 cnx.commit() |
84 self.repo.looping_task(60*60*24, expire_dataimports, self.repo) |
84 self.repo.looping_task(60*60*24, expire_dataimports, self.repo) |