'Delete the workflow deployment directory.'

def remove_deployment_dir(self):

    try:
        path = self.job.deployment_dir
        if self._do_as(self.user.username, self.fs.exists, path):
            self._do_as(self.user.username, self.fs.rmtree, path)
    except Exception as ex:
        LOG.warn('Failed    to    clean    up    workflow    deployment    directory    for    %s    (owner    %s).    Caused    by:    %s', self.job.name, self.user, ex)
