Fetch the stored payload for a run id.
(run_id: str)
| 28 | |
| 29 | |
| 30 | async def get_run_payload(run_id: str) -> dict[str, Any] | None: |
| 31 | """Fetch the stored payload for a run id.""" |
| 32 | val = await cache.get(_cache_key(run_id)) |
| 33 | return dict(val) if isinstance(val, dict) else None |
| 34 | |
| 35 | |
| 36 | async def update_run_project(run_id: str, project: dict[str, str]) -> None: |
no test coverage detected