Build an end-of-stream message dict. Args: request_id: Request identifier this ends Returns: dict: End message dict
(request_id)
| 744 | |
| 745 | |
| 746 | def make_end_message(request_id) -> dict: |
| 747 | """ |
| 748 | Build an end-of-stream message dict. |
| 749 | |
| 750 | Args: |
| 751 | request_id: Request identifier this ends |
| 752 | |
| 753 | Returns: |
| 754 | dict: End message dict |
| 755 | """ |
| 756 | return { |
| 757 | "type": DirtyProtocol.MSG_TYPE_END, |
| 758 | "id": request_id, |
| 759 | } |
| 760 | |
| 761 | |
| 762 | def make_stash_message(request_id, op: int, table: str, |
no outgoing calls