Remove log file when shutting down offload worker

This commit is contained in:
Kovid Goyal 2013-11-05 22:10:12 +05:30
parent 144fa523ef
commit d50c85b885

View File

@ -74,7 +74,11 @@ class OffloadWorker(object):
finally: finally:
self.conn = None self.conn = None
t = Thread(target=self.worker.kill) t = Thread(target=self.worker.kill)
t.daemon=True t.daemon = True
try:
os.remove(self.worker.log_path)
except:
pass
t.start() t.start()
def communicate(ans, worker, listener, args, timeout=300, heartbeat=None, def communicate(ans, worker, listener, args, timeout=300, heartbeat=None,