apache_beam.portability.api.beam_artifact_api_pb2_grpc module

Client and server classes corresponding to protobuf-defined services.

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactRetrievalServiceStub(channel)

Bases: object

A service to retrieve artifacts for use in a Job.

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactRetrievalServiceServicer

Bases: object

A service to retrieve artifacts for use in a Job.

ResolveArtifacts(request, context)

Resolves the given artifact references into one or more replacement artifact references (e.g. a Maven dependency into a (transitive) set of jars.

GetArtifact(request, context)

Retrieves the given artifact as a stream of bytes.

apache_beam.portability.api.beam_artifact_api_pb2_grpc.add_ArtifactRetrievalServiceServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactRetrievalService

Bases: object

A service to retrieve artifacts for use in a Job.

static ResolveArtifacts(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static GetArtifact(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactStagingServiceStub(channel)

Bases: object

A service that allows the client to act as an ArtifactRetrievalService, for a particular job with the server initiating requests and receiving responses.

A client calls the service with an ArtifactResponseWrapper that has the staging token set, and thereafter responds to the server’s requests.

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactStagingServiceServicer

Bases: object

A service that allows the client to act as an ArtifactRetrievalService, for a particular job with the server initiating requests and receiving responses.

A client calls the service with an ArtifactResponseWrapper that has the staging token set, and thereafter responds to the server’s requests.

ReverseArtifactRetrievalService(request_iterator, context)

Missing associated documentation comment in .proto file.

apache_beam.portability.api.beam_artifact_api_pb2_grpc.add_ArtifactStagingServiceServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactStagingService

Bases: object

A service that allows the client to act as an ArtifactRetrievalService, for a particular job with the server initiating requests and receiving responses.

A client calls the service with an ArtifactResponseWrapper that has the staging token set, and thereafter responds to the server’s requests.

static ReverseArtifactRetrievalService(request_iterator, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.LegacyArtifactStagingServiceStub(channel)

Bases: object

Legacy artifact staging service for pipeline-level artifacts.

A service to stage artifacts for use in a Job.

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.LegacyArtifactStagingServiceServicer

Bases: object

Legacy artifact staging service for pipeline-level artifacts.

A service to stage artifacts for use in a Job.

PutArtifact(request_iterator, context)

Stage an artifact to be available during job execution. The first request must contain the name of the artifact. All future requests must contain sequential chunks of the content of the artifact.

CommitManifest(request, context)

Commit the manifest for a Job. All artifacts must have been successfully uploaded before this call is made.

Throws error INVALID_ARGUMENT if not all of the members of the manifest are present

apache_beam.portability.api.beam_artifact_api_pb2_grpc.add_LegacyArtifactStagingServiceServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.LegacyArtifactStagingService

Bases: object

Legacy artifact staging service for pipeline-level artifacts.

A service to stage artifacts for use in a Job.

static PutArtifact(request_iterator, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static CommitManifest(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.LegacyArtifactRetrievalServiceStub(channel)

Bases: object

A service to retrieve artifacts for use in a Job.

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.LegacyArtifactRetrievalServiceServicer

Bases: object

A service to retrieve artifacts for use in a Job.

GetManifest(request, context)

Get the manifest for the job

GetArtifact(request, context)

Get an artifact staged for the job. The requested artifact must be within the manifest

apache_beam.portability.api.beam_artifact_api_pb2_grpc.add_LegacyArtifactRetrievalServiceServicer_to_server(servicer, server)

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.LegacyArtifactRetrievalService

Bases: object

A service to retrieve artifacts for use in a Job.

static GetManifest(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static GetArtifact(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)