Synchronous version of RPC call.
(self, method_name, *args, **kwargs)
| 527 | time.sleep(0.2) |
| 528 | |
| 529 | def _call_sync(self, method_name, *args, **kwargs): |
| 530 | """Synchronous version of RPC call.""" |
| 531 | if enable_llmapi_debug() or logger.level == 'debug': |
| 532 | logger_debug(f"[client] RPC Client calling method: {method_name}") |
| 533 | nvtx_mark_debug(f"RPC.sync.{method_name}", |
| 534 | color="green", |
| 535 | category="RPC") |
| 536 | future = asyncio.run_coroutine_threadsafe( |
| 537 | self._call_async(method_name, *args, **kwargs), self._loop) |
| 538 | result = future.result() |
| 539 | return result |
| 540 | |
| 541 | def _call_future(self, name: str, *args, |
| 542 | **kwargs) -> concurrent.futures.Future: |
nothing calls this directly
no test coverage detected