nebius.aio.request.Request

class documentation

class Request(Generic[Req, Res]): (source)

Constructor: Request(channel, service, method, request, ...)

View In Hierarchy

Undocumented

Method __await__ Undocumented
Method __init__ Undocumented
Method __repr__ Undocumented
Method cancel Undocumented
Method cancelled Undocumented
Method compression.setter Undocumented
Method credentials.setter Undocumented
Method current_status Undocumented
Method done Undocumented
Async Method initial_metadata Undocumented
Method initial_metadata_sync Undocumented
Method input_metadata Undocumented
Async Method request_id Undocumented
Method request_id_sync Undocumented
Method run_sync_with_timeout Undocumented
Async Method status Undocumented
Method timeout.setter Undocumented
Async Method trace_id Undocumented
Method trace_id_sync Undocumented
Async Method trailing_metadata Undocumented
Method trailing_metadata_sync Undocumented
Method wait Undocumented
Method wait_for_ready.setter Undocumented
Property compression Undocumented
Property credentials Undocumented
Property timeout Undocumented
Property wait_for_ready Undocumented
Async Method _await_result Undocumented
Method _convert_request_error Undocumented
Async Method _get_request_id Undocumented
Method _parse_request_id Undocumented
Method _raise_request_error Undocumented
Async Method _retry_loop Undocumented
Method _send Undocumented
Instance Variable _awaited Undocumented
Instance Variable _call Undocumented
Instance Variable _cancelled Undocumented
Instance Variable _channel Undocumented
Instance Variable _compression Undocumented
Instance Variable _credentials Undocumented
Instance Variable _error_wrapper Undocumented
Instance Variable _future Undocumented
Instance Variable _grpc_channel Undocumented
Instance Variable _initial_metadata Undocumented
Instance Variable _input Undocumented
Instance Variable _input_metadata Undocumented
Instance Variable _method Undocumented
Instance Variable _per_retry_timeout Undocumented
Instance Variable _request_id Undocumented
Instance Variable _result_pb2_class Undocumented
Instance Variable _result_wrapper Undocumented
Instance Variable _retries Undocumented
Instance Variable _sent Undocumented
Instance Variable _service Undocumented
Instance Variable _start_time Undocumented
Instance Variable _status Undocumented
Instance Variable _timeout Undocumented
Instance Variable _trace_id Undocumented
Instance Variable _trailing_metadata Undocumented
Instance Variable _wait_for_ready Undocumented
def __await__(self) -> Generator[Any, None, Res]: (source)

Undocumented

def __init__(self, channel: Channel, service: str, method: str, request: Req, result_pb2_class: type[PMessage], metadata: Metadata | Iterable[tuple[str, str]] | None = None, timeout: float | None = None, credentials: CallCredentials | None = None, compression: Compression | None = None, result_wrapper: Callable[[str, Channel, Any], Res] | None = None, grpc_channel_override: AddressChannel | None = None, error_wrapper: Callable[[RequestStatus], RequestError] | None = None, retries: int | None = 3, per_retry_timeout: float | None = None): (source)

Undocumented

def __repr__(self) -> str: (source)

Undocumented

def cancel(self) -> bool: (source)

Undocumented

def cancelled(self) -> bool: (source)

Undocumented

def compression(self, compression: Compression | None): (source)

Undocumented

def credentials(self, credentials: CallCredentials | None): (source)

Undocumented

def current_status(self) -> RequestStatus | UnfinishedRequestStatus: (source)

Undocumented

def done(self) -> bool: (source)

Undocumented

async def initial_metadata(self) -> Metadata: (source)

Undocumented

def initial_metadata_sync(self) -> Metadata: (source)

Undocumented

def input_metadata(self) -> Metadata: (source)

Undocumented

async def request_id(self) -> str: (source)

Undocumented

def request_id_sync(self) -> str: (source)

Undocumented

def run_sync_with_timeout(self, func: Awaitable[T]) -> T: (source)

Undocumented

async def status(self) -> RequestStatus: (source)

Undocumented

def timeout(self, timeout: float | None): (source)

Undocumented

async def trace_id(self) -> str: (source)

Undocumented

def trace_id_sync(self) -> str: (source)

Undocumented

async def trailing_metadata(self) -> Metadata: (source)

Undocumented

def trailing_metadata_sync(self) -> Metadata: (source)

Undocumented

def wait(self) -> Res: (source)

Undocumented

def wait_for_ready(self, wait_for_ready: bool | None): (source)

Undocumented

compression: Compression | None = (source)

Undocumented

credentials: CallCredentials | None = (source)

Undocumented

timeout: float | None = (source)

Undocumented

wait_for_ready: bool | None = (source)

Undocumented

async def _await_result(self) -> Res: (source)

Undocumented

def _convert_request_error(self, err: AioRpcError): (source)

Undocumented

async def _get_request_id(self) -> tuple[str, str]: (source)

Undocumented

def _parse_request_id(self): (source)

Undocumented

def _raise_request_error(self, err: AioRpcError): (source)

Undocumented

async def _retry_loop(self) -> Res: (source)

Undocumented

def _send(self, timeout: float | None): (source)

Undocumented

_awaited: bool = (source)

Undocumented

_call: UnaryUnaryCall | None = (source)

Undocumented

_cancelled: bool = (source)

Undocumented

_channel = (source)

Undocumented

_compression = (source)

Undocumented

_credentials = (source)

Undocumented

_error_wrapper = (source)

Undocumented

_future: Future[Res] | None = (source)

Undocumented

_grpc_channel = (source)

Undocumented

_initial_metadata: Metadata | None = (source)

Undocumented

_input = (source)

Undocumented

_input_metadata = (source)

Undocumented

_method = (source)

Undocumented

_per_retry_timeout = (source)

Undocumented

_request_id: str | None = (source)

Undocumented

_result_pb2_class = (source)

Undocumented

_result_wrapper = (source)

Undocumented

_retries = (source)

Undocumented

_sent: bool = (source)

Undocumented

_service = (source)

Undocumented

_start_time = (source)

Undocumented

_status: RequestStatusExtended | None = (source)

Undocumented

_timeout = (source)

Undocumented

_trace_id: str | None = (source)

Undocumented

_trailing_metadata: Metadata | None = (source)

Undocumented

_wait_for_ready = (source)

Undocumented