'Removes any incomplete cache entries older than a
supplied modified time.
:param older_than: Files written to on or before this timestamp
will be deleted.'

def delete_stalled_files(self, older_than):

    for path in self.get_cache_files(self.incomplete_dir):
        if (os.path.getmtime(path) < older_than):
            try:
                fileutils.delete_if_exists(path)
                LOG.info(_LI('Removed    stalled    cache    file    %s'), path)
            except Exception as e:
                msg = (_LW('Failed    to    delete    file    %(path)s.    Got    error:    %(e)s'), dict(path=path, e=e))
                LOG.warn(msg)
