flytekit.clients.grpc_utils.default_metadata_interceptor

Directory

Classes

flytekit.clients.grpc_utils.default_metadata_interceptor.DefaultMetadataInterceptor

Affords intercepting unary-unary invocations.

Methods

intercept_unary_stream()

def intercept_unary_stream(
    continuation: typing.Callable,
    client_call_details: grpc.ClientCallDetails,
    request: typing.Any,
):

Handles a stream call and inject default metadata

intercept_unary_unary()

def intercept_unary_unary(
    continuation: typing.Callable,
    client_call_details: grpc.ClientCallDetails,
    request: typing.Any,
):

Intercepts unary calls and inject default metadata