Push wafcache files synchronously for now

This commit is contained in:
Thomas Nagy 2019-10-23 19:52:06 +02:00
parent 6ef3a95c48
commit a6ff2fc274
No known key found for this signature in database
GPG Key ID: 49B4C67C05277AAA
1 changed files with 2 additions and 4 deletions

View File

@ -431,10 +431,8 @@ def loop(service):
[sig, files_from, files_to] = cPickle.loads(base64.b64decode(txt))
if files_from:
# pushing to cache is done without any wait
th = threading.Thread(target=service.copy_to_cache, args=(sig, files_from, files_to))
th.setDaemon(True)
th.start()
# TODO return early when pushing files upstream
ret = service.copy_from_cache(sig, files_from, files_to)
elif files_to:
# the build process waits for workers to (possibly) obtain files from the cache
ret = service.copy_from_cache(sig, files_from, files_to)