flytekit.clients.grpc_utils.wrap_exception_interceptor

Directory

Classes

Errors

• FlyteAuthenticationException
• FlyteEntityAlreadyExistsException
• FlyteEntityNotExistException
• FlyteException
• FlyteInvalidInputException
• FlyteSystemException
• FlyteSystemUnavailableException

flytekit.clients.grpc_utils.wrap_exception_interceptor.FlyteAuthenticationException

Assertion failed.

def FlyteAuthenticationException(
    args,
    timestamp: typing.Optional[float],
):

Properties

flytekit.clients.grpc_utils.wrap_exception_interceptor.FlyteEntityAlreadyExistsException

Assertion failed.

def FlyteEntityAlreadyExistsException(
    args,
    timestamp: typing.Optional[float],
):

Properties

flytekit.clients.grpc_utils.wrap_exception_interceptor.FlyteEntityNotExistException

Assertion failed.

def FlyteEntityNotExistException(
    args,
    timestamp: typing.Optional[float],
):

Properties

flytekit.clients.grpc_utils.wrap_exception_interceptor.FlyteException

Common base class for all non-exit exceptions.

def FlyteException(
    args,
    timestamp: typing.Optional[float],
):

Properties

flytekit.clients.grpc_utils.wrap_exception_interceptor.FlyteInvalidInputException

Common base class for all non-exit exceptions.

def FlyteInvalidInputException(
    request: typing.Any,
):

Properties

flytekit.clients.grpc_utils.wrap_exception_interceptor.FlyteSystemException

Common base class for all non-exit exceptions.

def FlyteSystemException(
    args,
    timestamp: typing.Optional[float],
):

Properties

flytekit.clients.grpc_utils.wrap_exception_interceptor.FlyteSystemUnavailableException

Common base class for all non-exit exceptions.

def FlyteSystemUnavailableException(
    args,
    timestamp: typing.Optional[float],
):

Properties

flytekit.clients.grpc_utils.wrap_exception_interceptor.RetryExceptionWrapperInterceptor

Affords intercepting unary-unary invocations.

def RetryExceptionWrapperInterceptor(
    max_retries: int,
):

Methods

intercept_unary_stream()

def intercept_unary_stream(
    continuation,
    client_call_details,
    request,
):

Intercepts a unary-stream invocation.

intercept_unary_unary()

def intercept_unary_unary(
    continuation,
    client_call_details,
    request,
):

Intercepts a unary-unary invocation asynchronously.