Ver Fonte

Always remove task work dir on Exception.

Nashwan Azhari há 8 anos atrás
pai
commit
9f115357bb
1 ficheiros alterados com 1 adições e 0 exclusões
  1. 1 0
      coriolis/worker/rpc/server.py

+ 1 - 0
coriolis/worker/rpc/server.py

@@ -163,6 +163,7 @@ class WorkerServerEndpoint(object):
                                                       new_task_info)
                                                       new_task_info)
         except Exception as ex:
         except Exception as ex:
             LOG.exception(ex)
             LOG.exception(ex)
+            self._check_remove_dir(export_path)
             self._rpc_conductor_client.set_task_error(ctxt, task_id, str(ex))
             self._rpc_conductor_client.set_task_error(ctxt, task_id, str(ex))
         finally:
         finally:
             if not retain_export_path:
             if not retain_export_path: