if not ssig in all_sigs_in_cache[1]:
raise ValueError('no file %s in cache' % ssig)
+class MissingFile(Exception):
+ pass
+
def recv_file(conn, ssig, count, p):
check_cache(conn, ssig)
size = int(data.split(',')[0])
if size == -1:
- raise ValueError('no file %s - %s in cache' % (ssig, count))
+ raise MissingFile('no file %s - %s in cache' % (ssig, count))
# get the file, writing immediately
# TODO a tmp file would be better
conn = None
err = False
try:
- conn = get_connection()
try:
+ conn = get_connection()
for node in self.outputs:
p = node.abspath()
recv_file(conn, ssig, cnt, p)
cnt += 1
+ except MissingFile:
+ Logs.debug('netcache: file is not in the cache %r' % e)
+ err = True
+
except Exception, e:
Logs.debug('netcache: could not get the files %r' % e)
err = True