|
1 | | -from typing import List, Optional, Tuple |
2 | 1 | import grpc |
3 | 2 |
|
4 | | -from google.protobuf.internal.containers import RepeatedCompositeFieldContainer |
5 | | - |
6 | | -import types_jobs as types |
7 | 3 | from tamr.api.v1beta1.jobs_pb2_grpc import JobsStub |
8 | 4 | from tamr.api.v1beta1 import jobs_pb2 as jobs |
9 | 5 |
|
10 | | - |
11 | 6 | class JobsClient: |
12 | | - def __init__(self, host: str, metadata: List[Tuple[str, str]]) -> None: |
13 | | - credentials: grpc.ChannelCredentials = grpc.ssl_channel_credentials() |
14 | | - channel: grpc.Channel = grpc.secure_channel(host, credentials) |
| 7 | + def __init__(self, host, metadata): |
| 8 | + credentials = grpc.ssl_channel_credentials() |
| 9 | + channel = grpc.secure_channel(host, credentials) |
15 | 10 | self.metadata = metadata |
16 | 11 | self.stub = JobsStub(channel) |
17 | 12 |
|
18 | | - def get_job(self, job_id: str) -> types.Job: |
| 13 | + def get_job(self, job_id): |
19 | 14 | request = jobs.GetJobRequest(job_id=job_id) |
20 | 15 | return self.stub.GetJob(request, metadata=self.metadata) |
21 | 16 |
|
22 | | - def list_jobs( |
23 | | - self, page_size: int = 10, page_token: Optional[str] = None |
24 | | - ) -> types.ListJobsResponse: |
25 | | - request = jobs.ListJobsRequest(page_size=page_size, page_token=page_token) |
| 17 | + def list_jobs(self, page_size=10, page_token=None): |
| 18 | + request = jobs.ListJobsRequest( |
| 19 | + page_size=page_size, |
| 20 | + page_token=page_token |
| 21 | + ) |
26 | 22 | return self.stub.ListJobs(request, metadata=self.metadata) |
27 | 23 |
|
28 | | - def stop_job(self, job_id: str) -> types.StopJobResponse: |
| 24 | + def stop_job(self, job_id): |
29 | 25 | request = jobs.StopJobRequest(job_id=job_id) |
30 | 26 | return self.stub.StopJob(request, metadata=self.metadata) |
31 | 27 |
|
32 | | - def create_job( |
33 | | - self, job_definition: types.CreateJobRequest |
34 | | - ) -> types.CreateJobResponse: |
| 28 | + def create_job(self, job_definition): |
35 | 29 | request = jobs.CreateJobRequest(job=job_definition) |
36 | 30 | return self.stub.CreateJob(request, metadata=self.metadata) |
0 commit comments