(self, state: serializable.State)
| 159 | return state |
| 160 | |
| 161 | def set_state(self, state: serializable.State) -> None: |
| 162 | assert state.pop("version") == version.FLOW_FORMAT_VERSION |
| 163 | assert state.pop("type") == self.type |
| 164 | self.id = state.pop("id") |
| 165 | if state["error"]: |
| 166 | if self.error: |
| 167 | self.error.set_state(state.pop("error")) |
| 168 | else: |
| 169 | self.error = Error.from_state(state.pop("error")) |
| 170 | else: |
| 171 | self.error = state.pop("error") |
| 172 | self.client_conn.set_state(state.pop("client_conn")) |
| 173 | self.server_conn.set_state(state.pop("server_conn")) |
| 174 | self.intercepted = state.pop("intercepted") |
| 175 | self.is_replay = state.pop("is_replay") |
| 176 | self.marked = state.pop("marked") |
| 177 | self.metadata = state.pop("metadata") |
| 178 | self.comment = state.pop("comment") |
| 179 | self.timestamp_created = state.pop("timestamp_created") |
| 180 | self._backup = state.pop("backup", None) |
| 181 | assert state == {} |
| 182 | |
| 183 | @classmethod |
| 184 | def from_state(cls, state: serializable.State) -> Flow: |
no test coverage detected