|
|
@@ -12,7 +12,7 @@ r = redis.StrictRedis.from_url(os.environ.get('REDIS_URL', 'redis://127.0.0.1:16 |
|
|
|
curDownloaded, curQueued = r.hmget(jobid, 'items_downloaded', 'items_queued') |
|
|
|
assert curDownloaded is not None and curQueued is not None, f'could not fetch downloaded and/or queued count for {jobid}' |
|
|
|
|
|
|
|
print(f'Current control node values: {curDownloaded}/{curQueued} (net {curQueued - curDownloaded})') |
|
|
|
print(f'Current control node values: {curDownloaded}/{curQueued} (net {int(curQueued) - int(curDownloaded)})') |
|
|
|
|
|
|
|
db = sqlite3.connect('wpull.db') |
|
|
|
cur = db.cursor() |
|
|
|