14 lines
470 B
Python
14 lines
470 B
Python
|
from collections.abc import Awaitable, Callable
|
||
|
|
from typing import Any
|
||
|
|
|
||
|
|
|
||
|
|
class ConfigCacheWorker:
|
||
|
|
def __init__(self, delete_key: Callable[[str], Awaitable[None]]) -> None:
|
||
|
|
self.delete_key = delete_key
|
||
|
|
|
||
|
|
async def handle(self, payload: dict[str, Any]) -> None:
|
||
|
|
release_id = payload.get("release_id")
|
||
|
|
if release_id is None:
|
||
|
|
raise ValueError("release_id is required")
|
||
|
|
await self.delete_key(f"config:release:{release_id}")
|