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 _request_with_authorization_loop Wrap request retry loop with an authorization loop.
Async Method _retry_loop Undocumented
Method _send Undocumented
Instance Variable _auth_options Undocumented
Instance Variable _auth_timeout 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 | UnsetType = Unset, auth_timeout: float | None | UnsetType = Unset, auth_options: dict[str, str] | 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 | UnsetType = Unset): (source)

Undocumented

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

Undocumented

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

Undocumented

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

Undocumented

@compression.setter
def compression(self, compression: Compression | None): (source)

Undocumented

@credentials.setter
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

@timeout.setter
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

@wait_for_ready.setter
def wait_for_ready(self, wait_for_ready: bool | None): (source)

Undocumented

@property
compression: Compression | None = (source)

Undocumented

@property
credentials: CallCredentials | None = (source)

Undocumented

@property
timeout: float | None = (source)

Undocumented

@property
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 _request_with_authorization_loop(self) -> Res: (source)

Wrap request retry loop with an authorization loop.

The authorization loop will attempt to authenticate and then execute the request retry loop. If the result is UNAUTHENTICATED and the authenticator allows retry, it will re-authenticate and try again while respecting the overall auth timeout.

async def _retry_loop(self, outer_deadline: float | None = None) -> Res: (source)

Undocumented

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

Undocumented

_auth_options = (source)

Undocumented

_auth_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: float | None = (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: float | None = (source)

Undocumented

_trace_id: str | None = (source)

Undocumented

_trailing_metadata: Metadata | None = (source)

Undocumented

_wait_for_ready = (source)

Undocumented