ReMe/reme/steps/index/clear_store.py
2026-06-22 15:41:19 +08:00

16 lines
573 B
Python

"""Clear the file store before reusing the standard init change producer."""
from ..base_step import BaseStep
from ...components import R
@R.register("clear_store_step")
class ClearStoreStep(BaseStep):
"""Wipe ``file_store`` so ``init_changes_step(store=file_store)`` sees all files as added."""
async def execute(self):
assert self.context is not None
await self.file_store.clear()
self.context.response.metadata["cleared_store"] = True
self.logger.info(f"[{self.name}] cleared file_store")
return self.context.response