apache_beam.portability.api.beam_artifact_api_pb2_grpc module

class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactStagingServiceStub(channel)[source]

Bases: object

A service to stage artifacts for use in a Job.

RPCs made to an ArtifactStagingService endpoint should include some form of identification for the job as a header.

Constructor.

Parameters:channel – A grpc.Channel.
class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactStagingServiceServicer[source]

Bases: object

A service to stage artifacts for use in a Job.

RPCs made to an ArtifactStagingService endpoint should include some form of identification for the job as a header.

PutArtifact(request_iterator, context)[source]

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)[source]

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_ArtifactStagingServiceServicer_to_server(servicer, server)[source]
class apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactRetrievalServiceStub(channel)[source]

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[source]

Bases: object

A service to retrieve artifacts for use in a Job.

GetManifest(request, context)[source]

Get the manifest for the job

GetArtifact(request, context)[source]

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_ArtifactRetrievalServiceServicer_to_server(servicer, server)[source]