(self, server_state)
| 485 | self.name = state |
| 486 | |
| 487 | def process_request(self, server_state): |
| 488 | kv_store = server_state.kv_store |
| 489 | if self.name not in kv_store.data_store: |
| 490 | raise RuntimeError( |
| 491 | "KVServer Cannot find data tensor with name: %s" % self.name |
| 492 | ) |
| 493 | data_shape = F.shape(kv_store.data_store[self.name]) |
| 494 | res = GetPartShapeResponse(data_shape) |
| 495 | return res |
| 496 | |
| 497 | |
| 498 | SEND_META_TO_BACKUP = 901239 |
nothing calls this directly
no test coverage detected