This commit is contained in:
JerryXiao 2019-09-06 15:16:24 +08:00
parent 96e76dfc40
commit 6e15ce66ea
Signed by: Jerry
GPG key ID: 9D9CE43650FF2BAA
2 changed files with 3 additions and 3 deletions

View file

@ -263,7 +263,7 @@ class jobsManager:
sizes = [f.stat().st_size / 1000 / 1000 for f in f_to_upload] sizes = [f.stat().st_size / 1000 / 1000 for f in f_to_upload]
max_tries = 10 max_tries = 10
for tries in range(max_tries): for tries in range(max_tries):
timeouts = rrun('push_start', args=(f_to_upload, sizes)) timeouts = rrun('push_start', args=([f.name for f in f_to_upload], sizes))
if type(timeouts) is list: if type(timeouts) is list:
break break
else: else:
@ -299,7 +299,7 @@ class jobsManager:
max_tries = 5 max_tries = 5
for tries in range(max_tries): for tries in range(max_tries):
try: try:
res = rrun('push_done', args=(f_to_upload,), kwargs={'overwrite': overwrite,}) res = rrun('push_done', args=([f.name for f in f_to_upload],), kwargs={'overwrite': overwrite,})
except Exception: except Exception:
time_to_sleep = (tries + 1) * 60 time_to_sleep = (tries + 1) * 60
logger.info(f'Error updating {pkg_update_list}, wait {time_to_sleep} secs') logger.info(f'Error updating {pkg_update_list}, wait {time_to_sleep} secs')

View file

@ -175,7 +175,7 @@ if __name__ == '__main__':
try: try:
with Listener(REPOD_BIND_ADDRESS, authkey=REPOD_BIND_PASSWD) as listener: with Listener(REPOD_BIND_ADDRESS, authkey=REPOD_BIND_PASSWD) as listener:
with listener.accept() as conn: with listener.accept() as conn:
logger.info('connection accepted from %s', listener.last_accepted) logger.debug('connection accepted from %s', listener.last_accepted)
myrecv = conn.recv() myrecv = conn.recv()
if type(myrecv) is list and len(myrecv) == 3: if type(myrecv) is list and len(myrecv) == 3:
(funcname, args, kwargs) = myrecv (funcname, args, kwargs) = myrecv