Push wafcache files synchronously for now

This commit is contained in:
Thomas Nagy 2019-10-23 19:52:06 +02:00
parent 2702017dd3
commit bd5ae88e15
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)) [sig, files_from, files_to] = cPickle.loads(base64.b64decode(txt))
if files_from: if files_from:
# pushing to cache is done without any wait # TODO return early when pushing files upstream
th = threading.Thread(target=service.copy_to_cache, args=(sig, files_from, files_to)) ret = service.copy_from_cache(sig, files_from, files_to)
th.setDaemon(True)
th.start()
elif files_to: elif files_to:
# the build process waits for workers to (possibly) obtain files from the cache # the build process waits for workers to (possibly) obtain files from the cache
ret = service.copy_from_cache(sig, files_from, files_to) ret = service.copy_from_cache(sig, files_from, files_to)