Add additional logs

This commit is contained in:
Joseph Schorr 2019-01-16 11:39:57 -05:00
parent 0f18b3a70a
commit 1cda16f055

View file

@ -119,6 +119,7 @@ class TagBackfillWorker(Worker):
def _filter(self, query): def _filter(self, query):
if self._namespace_filter: if self._namespace_filter:
logger.info('Filtering by namespace `%s`', self._namespace_filter)
namespace_user = get_namespace_user(self._namespace_filter) namespace_user = get_namespace_user(self._namespace_filter)
query = query.join(Repository).where(Repository.namespace_user == namespace_user) query = query.join(Repository).where(Repository.namespace_user == namespace_user)
@ -133,6 +134,8 @@ class TagBackfillWorker(Worker):
min_id = (self._filter(RepositoryTag.select(fn.Min(RepositoryTag.id))).scalar()) min_id = (self._filter(RepositoryTag.select(fn.Min(RepositoryTag.id))).scalar())
max_id = self._filter(RepositoryTag.select(fn.Max(RepositoryTag.id))).scalar() max_id = self._filter(RepositoryTag.select(fn.Max(RepositoryTag.id))).scalar()
logger.info('Found candidate range %s-%s', min_id, max_id)
iterator = yield_random_entries( iterator = yield_random_entries(
missing_tmt_query, missing_tmt_query,
RepositoryTag.id, RepositoryTag.id,