aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorKonstantin Ryabitsev <konstantin@linuxfoundation.org>2020-07-16 11:44:55 -0400
committerKonstantin Ryabitsev <konstantin@linuxfoundation.org>2020-07-16 11:44:55 -0400
commit100a4d82b8801479f459ca5bbd824d1e3da5ed87 (patch)
tree94bc951228d4695b4f7b4c2e2bcdcee685cea488
parent166faa1a6ac96330dcfe34a33d612d4d9e69cf60 (diff)
downloadgrokmirror-100a4d82b8801479f459ca5bbd824d1e3da5ed87.tar.gz
Another small UI tweak
Tell us about how many spa repos are active and how many waiting. Signed-off-by: Konstantin Ryabitsev <konstantin@linuxfoundation.org>
-rwxr-xr-xgrokmirror/pull.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/grokmirror/pull.py b/grokmirror/pull.py
index 53f10ee..6adb595 100755
--- a/grokmirror/pull.py
+++ b/grokmirror/pull.py
@@ -187,6 +187,11 @@ def spa_worker(config, q_spa):
# We'll get it during grok-fsck
continue
+ if not q_spa.empty():
+ logger.info(' spa: 1 active, %s waiting', q_spa.qsize())
+ else:
+ logger.info(' spa: 1 active')
+
done = list()
for action in actions:
if action in done:
@@ -217,8 +222,6 @@ def spa_worker(config, q_spa):
grokmirror.unlock_repo(fullpath)
logger.info(' spa: %s (done: %s)', gitdir, ', '.join(done))
- if not q_spa.empty():
- logger.info(' spa: %s waiting', q_spa.qsize())
def pull_worker(config, q_pull, q_spa, q_done):