Stage a request state for commit; flush when last active request ends.
(cls, request_uid: str)
| 737 | |
| 738 | @classmethod |
| 739 | def finalize_request(cls, request_uid: str) -> None: |
| 740 | """Stage a request state for commit; flush when last active request ends.""" |
| 741 | if not request_uid: |
| 742 | return |
| 743 | with cls._request_lock: |
| 744 | state = cls._request_states.pop(request_uid, None) |
| 745 | if state is None: |
| 746 | return |
| 747 | cls._staged_commits.append(state) |
| 748 | cls._active_requests.discard(request_uid) |
| 749 | if not cls._active_requests: |
| 750 | cls._commit_staged_states_locked() |
| 751 | |
| 752 | @classmethod |
| 753 | def _commit_staged_states_locked(cls) -> None: |
nothing calls this directly
no test coverage detected