Skip to content

Commit 38b1b9c

Browse files
viambotviambot
authored
Automated Protos Update (#881)
Co-authored-by: viambot <[email protected]>
1 parent 90eb8d1 commit 38b1b9c

File tree

5 files changed

+120
-102
lines changed

5 files changed

+120
-102
lines changed

‎src/viam/gen/app/datapipelines/v1/data_pipelines_pb2.py‎

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
_runtime_version.ValidateProtobufRuntimeVersion(_runtime_version.Domain.PUBLIC, 5, 29, 2, '', 'app/datapipelines/v1/data_pipelines.proto')
88
_sym_db = _symbol_database.Default()
99
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
10-
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n)app/datapipelines/v1/data_pipelines.proto\x12\x19viam.app.datapipelines.v1\x1a\x1fgoogle/protobuf/timestamp.proto"\xa6\x02\n\x0cDataPipeline\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\'\n\x0forganization_id\x18\x02 \x01(\tR\x0eorganizationId\x12\x12\n\x04name\x18\x03 \x01(\tR\x04name\x12\x1d\n\nmql_binary\x18\x04 \x03(\x0cR\tmqlBinary\x12\x1a\n\x08schedule\x18\x05 \x01(\tR\x08schedule\x12\x18\n\x07enabled\x18\x06 \x01(\x08R\x07enabled\x129\n\ncreated_on\x18\x07 \x01(\x0b2\x1a.google.protobuf.TimestampR\tcreatedOn\x129\n\nupdated_at\x18\x08 \x01(\x0b2\x1a.google.protobuf.TimestampR\tupdatedAt"(\n\x16GetDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"g\n\x17GetDataPipelineResponse\x12L\n\rdata_pipeline\x18\x01 \x01(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\x0cdataPipeline"C\n\x18ListDataPipelinesRequest\x12\'\n\x0forganization_id\x18\x01 \x01(\tR\x0eorganizationId"k\n\x19ListDataPipelinesResponse\x12N\n\x0edata_pipelines\x18\x01 \x03(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\rdataPipelines"i\n\x19CreateDataPipelineRequest\x12L\n\rdata_pipeline\x18\x01 \x01(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\x0cdataPipeline",\n\x1aCreateDataPipelineResponse\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"y\n\x19UpdateDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12L\n\rdata_pipeline\x18\x02 \x01(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\x0cdataPipeline",\n\x1aUpdateDataPipelineResponse\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"+\n\x19DeleteDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"\x1c\n\x1aDeleteDataPipelineResponse2\x9c\x05\n\x14DataPipelinesService\x12x\n\x0fGetDataPipeline\x121.viam.app.datapipelines.v1.GetDataPipelineRequest\x1a2.viam.app.datapipelines.v1.GetDataPipelineResponse\x12~\n\x11ListDataPipelines\x123.viam.app.datapipelines.v1.ListDataPipelinesRequest\x1a4.viam.app.datapipelines.v1.ListDataPipelinesResponse\x12\x81\x01\n\x12CreateDataPipeline\x124.viam.app.datapipelines.v1.CreateDataPipelineRequest\x1a5.viam.app.datapipelines.v1.CreateDataPipelineResponse\x12\x81\x01\n\x12UpdateDataPipeline\x124.viam.app.datapipelines.v1.UpdateDataPipelineRequest\x1a5.viam.app.datapipelines.v1.UpdateDataPipelineResponse\x12\x81\x01\n\x12DeleteDataPipeline\x124.viam.app.datapipelines.v1.DeleteDataPipelineRequest\x1a5.viam.app.datapipelines.v1.DeleteDataPipelineResponseB&Z$go.viam.com/api/app/datapipelines/v1b\x06proto3')
10+
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n)app/datapipelines/v1/data_pipelines.proto\x12\x19viam.app.datapipelines.v1\x1a\x1fgoogle/protobuf/timestamp.proto"\xa6\x02\n\x0cDataPipeline\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\'\n\x0forganization_id\x18\x02 \x01(\tR\x0eorganizationId\x12\x12\n\x04name\x18\x03 \x01(\tR\x04name\x12\x1d\n\nmql_binary\x18\x04 \x03(\x0cR\tmqlBinary\x12\x1a\n\x08schedule\x18\x05 \x01(\tR\x08schedule\x12\x18\n\x07enabled\x18\x06 \x01(\x08R\x07enabled\x129\n\ncreated_on\x18\x07 \x01(\x0b2\x1a.google.protobuf.TimestampR\tcreatedOn\x129\n\nupdated_at\x18\x08 \x01(\x0b2\x1a.google.protobuf.TimestampR\tupdatedAt"(\n\x16GetDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"g\n\x17GetDataPipelineResponse\x12L\n\rdata_pipeline\x18\x01 \x01(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\x0cdataPipeline"C\n\x18ListDataPipelinesRequest\x12\'\n\x0forganization_id\x18\x01 \x01(\tR\x0eorganizationId"k\n\x19ListDataPipelinesResponse\x12N\n\x0edata_pipelines\x18\x01 \x03(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\rdataPipelines"\x93\x01\n\x19CreateDataPipelineRequest\x12\'\n\x0forganization_id\x18\x01 \x01(\tR\x0eorganizationId\x12\x12\n\x04name\x18\x02 \x01(\tR\x04name\x12\x1d\n\nmql_binary\x18\x03 \x03(\x0cR\tmqlBinary\x12\x1a\n\x08schedule\x18\x04 \x01(\tR\x08schedule",\n\x1aCreateDataPipelineResponse\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"\x94\x01\n\x19UpdateDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\x12\n\x04name\x18\x02 \x01(\tR\x04name\x12\x1d\n\nmql_binary\x18\x03 \x03(\x0cR\tmqlBinary\x12\x1a\n\x08schedule\x18\x04 \x01(\tR\x08schedule\x12\x18\n\x07enabled\x18\x05 \x01(\x08R\x07enabled"\x1c\n\x1aUpdateDataPipelineResponse"+\n\x19DeleteDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"\x1c\n\x1aDeleteDataPipelineResponse2\x9c\x05\n\x14DataPipelinesService\x12x\n\x0fGetDataPipeline\x121.viam.app.datapipelines.v1.GetDataPipelineRequest\x1a2.viam.app.datapipelines.v1.GetDataPipelineResponse\x12~\n\x11ListDataPipelines\x123.viam.app.datapipelines.v1.ListDataPipelinesRequest\x1a4.viam.app.datapipelines.v1.ListDataPipelinesResponse\x12\x81\x01\n\x12CreateDataPipeline\x124.viam.app.datapipelines.v1.CreateDataPipelineRequest\x1a5.viam.app.datapipelines.v1.CreateDataPipelineResponse\x12\x81\x01\n\x12UpdateDataPipeline\x124.viam.app.datapipelines.v1.UpdateDataPipelineRequest\x1a5.viam.app.datapipelines.v1.UpdateDataPipelineResponse\x12\x81\x01\n\x12DeleteDataPipeline\x124.viam.app.datapipelines.v1.DeleteDataPipelineRequest\x1a5.viam.app.datapipelines.v1.DeleteDataPipelineResponseB&Z$go.viam.com/api/app/datapipelines/v1b\x06proto3')
1111
_globals = globals()
1212
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
1313
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'app.datapipelines.v1.data_pipelines_pb2', _globals)
@@ -24,17 +24,17 @@
2424
_globals['_LISTDATAPIPELINESREQUEST']._serialized_end = 616
2525
_globals['_LISTDATAPIPELINESRESPONSE']._serialized_start = 618
2626
_globals['_LISTDATAPIPELINESRESPONSE']._serialized_end = 725
27-
_globals['_CREATEDATAPIPELINEREQUEST']._serialized_start = 727
28-
_globals['_CREATEDATAPIPELINEREQUEST']._serialized_end = 832
29-
_globals['_CREATEDATAPIPELINERESPONSE']._serialized_start = 834
30-
_globals['_CREATEDATAPIPELINERESPONSE']._serialized_end = 878
31-
_globals['_UPDATEDATAPIPELINEREQUEST']._serialized_start = 880
32-
_globals['_UPDATEDATAPIPELINEREQUEST']._serialized_end = 1001
33-
_globals['_UPDATEDATAPIPELINERESPONSE']._serialized_start = 1003
34-
_globals['_UPDATEDATAPIPELINERESPONSE']._serialized_end = 1047
35-
_globals['_DELETEDATAPIPELINEREQUEST']._serialized_start = 1049
36-
_globals['_DELETEDATAPIPELINEREQUEST']._serialized_end = 1092
37-
_globals['_DELETEDATAPIPELINERESPONSE']._serialized_start = 1094
38-
_globals['_DELETEDATAPIPELINERESPONSE']._serialized_end = 1122
39-
_globals['_DATAPIPELINESSERVICE']._serialized_start = 1125
40-
_globals['_DATAPIPELINESSERVICE']._serialized_end = 1793
27+
_globals['_CREATEDATAPIPELINEREQUEST']._serialized_start = 728
28+
_globals['_CREATEDATAPIPELINEREQUEST']._serialized_end = 875
29+
_globals['_CREATEDATAPIPELINERESPONSE']._serialized_start = 877
30+
_globals['_CREATEDATAPIPELINERESPONSE']._serialized_end = 921
31+
_globals['_UPDATEDATAPIPELINEREQUEST']._serialized_start = 924
32+
_globals['_UPDATEDATAPIPELINEREQUEST']._serialized_end = 1072
33+
_globals['_UPDATEDATAPIPELINERESPONSE']._serialized_start = 1074
34+
_globals['_UPDATEDATAPIPELINERESPONSE']._serialized_end = 1102
35+
_globals['_DELETEDATAPIPELINEREQUEST']._serialized_start = 1104
36+
_globals['_DELETEDATAPIPELINEREQUEST']._serialized_end = 1147
37+
_globals['_DELETEDATAPIPELINERESPONSE']._serialized_start = 1149
38+
_globals['_DELETEDATAPIPELINERESPONSE']._serialized_end = 1177
39+
_globals['_DATAPIPELINESSERVICE']._serialized_start = 1180
40+
_globals['_DATAPIPELINESSERVICE']._serialized_end = 1848

‎src/viam/gen/app/datapipelines/v1/data_pipelines_pb2.pyi‎

Lines changed: 38 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ class GetDataPipelineRequest(google.protobuf.message.Message):
6161
DESCRIPTOR: google.protobuf.descriptor.Descriptor
6262
ID_FIELD_NUMBER: builtins.int
6363
id: builtins.str
64+
'The ID of the data pipeline to retrieve.'
6465

6566
def __init__(self, *, id: builtins.str=...) -> None:
6667
...
@@ -93,6 +94,7 @@ class ListDataPipelinesRequest(google.protobuf.message.Message):
9394
DESCRIPTOR: google.protobuf.descriptor.Descriptor
9495
ORGANIZATION_ID_FIELD_NUMBER: builtins.int
9596
organization_id: builtins.str
97+
'The associated Viam organization ID.'
9698

9799
def __init__(self, *, organization_id: builtins.str=...) -> None:
98100
...
@@ -120,19 +122,27 @@ global___ListDataPipelinesResponse = ListDataPipelinesResponse
120122
@typing.final
121123
class CreateDataPipelineRequest(google.protobuf.message.Message):
122124
DESCRIPTOR: google.protobuf.descriptor.Descriptor
123-
DATA_PIPELINE_FIELD_NUMBER: builtins.int
125+
ORGANIZATION_ID_FIELD_NUMBER: builtins.int
126+
NAME_FIELD_NUMBER: builtins.int
127+
MQL_BINARY_FIELD_NUMBER: builtins.int
128+
SCHEDULE_FIELD_NUMBER: builtins.int
129+
organization_id: builtins.str
130+
'The associated Viam organization ID.'
131+
name: builtins.str
132+
'A unique identifier at the org level.'
133+
schedule: builtins.str
134+
'A cron expression representing the expected execution schedule in UTC (note this also\n defines the input time window; an hourly schedule would process 1 hour of data at a time).\n '
124135

125136
@property
126-
def data_pipeline(self) -> global___DataPipeline:
127-
...
128-
129-
def __init__(self, *, data_pipeline: global___DataPipeline | None=...) -> None:
130-
...
137+
def mql_binary(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]:
138+
"""A MongoDB aggregation pipeline as a list of BSON documents, where
139+
each document is one stage in the pipeline.
140+
"""
131141

132-
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
142+
def __init__(self, *, organization_id: builtins.str=..., name: builtins.str=..., mql_binary: collections.abc.Iterable[builtins.bytes] | None=..., schedule: builtins.str=...) -> None:
133143
...
134144

135-
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> None:
145+
def ClearField(self, field_name: typing.Literal['mql_binary', b'mql_binary', 'name', b'name', 'organization_id', b'organization_id', 'schedule', b'schedule']) -> None:
136146
...
137147
global___CreateDataPipelineRequest = CreateDataPipelineRequest
138148

@@ -141,6 +151,7 @@ class CreateDataPipelineResponse(google.protobuf.message.Message):
141151
DESCRIPTOR: google.protobuf.descriptor.Descriptor
142152
ID_FIELD_NUMBER: builtins.int
143153
id: builtins.str
154+
'The ID of the newly created data pipeline.'
144155

145156
def __init__(self, *, id: builtins.str=...) -> None:
146157
...
@@ -153,33 +164,37 @@ global___CreateDataPipelineResponse = CreateDataPipelineResponse
153164
class UpdateDataPipelineRequest(google.protobuf.message.Message):
154165
DESCRIPTOR: google.protobuf.descriptor.Descriptor
155166
ID_FIELD_NUMBER: builtins.int
156-
DATA_PIPELINE_FIELD_NUMBER: builtins.int
167+
NAME_FIELD_NUMBER: builtins.int
168+
MQL_BINARY_FIELD_NUMBER: builtins.int
169+
SCHEDULE_FIELD_NUMBER: builtins.int
170+
ENABLED_FIELD_NUMBER: builtins.int
157171
id: builtins.str
172+
'The ID of the data pipeline to update.'
173+
name: builtins.str
174+
'A unique identifier at the org level.'
175+
schedule: builtins.str
176+
'A cron expression representing the expected execution schedule in UTC (note this also\n defines the input time window; an hourly schedule would process 1 hour of data at a time).\n '
177+
enabled: builtins.bool
178+
'Whether or not the pipeline is enabled.'
158179

159180
@property
160-
def data_pipeline(self) -> global___DataPipeline:
161-
...
162-
163-
def __init__(self, *, id: builtins.str=..., data_pipeline: global___DataPipeline | None=...) -> None:
164-
...
181+
def mql_binary(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]:
182+
"""A MongoDB aggregation pipeline as a list of BSON documents, where
183+
each document is one stage in the pipeline.
184+
"""
165185

166-
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
186+
def __init__(self, *, id: builtins.str=..., name: builtins.str=..., mql_binary: collections.abc.Iterable[builtins.bytes] | None=..., schedule: builtins.str=..., enabled: builtins.bool=...) -> None:
167187
...
168188

169-
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline', 'id', b'id']) -> None:
189+
def ClearField(self, field_name: typing.Literal['enabled', b'enabled', 'id', b'id', 'mql_binary', b'mql_binary', 'name', b'name', 'schedule', b'schedule']) -> None:
170190
...
171191
global___UpdateDataPipelineRequest = UpdateDataPipelineRequest
172192

173193
@typing.final
174194
class UpdateDataPipelineResponse(google.protobuf.message.Message):
175195
DESCRIPTOR: google.protobuf.descriptor.Descriptor
176-
ID_FIELD_NUMBER: builtins.int
177-
id: builtins.str
178-
179-
def __init__(self, *, id: builtins.str=...) -> None:
180-
...
181196

182-
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
197+
def __init__(self) -> None:
183198
...
184199
global___UpdateDataPipelineResponse = UpdateDataPipelineResponse
185200

@@ -188,6 +203,7 @@ class DeleteDataPipelineRequest(google.protobuf.message.Message):
188203
DESCRIPTOR: google.protobuf.descriptor.Descriptor
189204
ID_FIELD_NUMBER: builtins.int
190205
id: builtins.str
206+
'The ID of the data pipeline to delete.'
191207

192208
def __init__(self, *, id: builtins.str=...) -> None:
193209
...

‎src/viam/gen/app/v1/app_pb2.py‎

Lines changed: 60 additions & 60 deletions
Large diffs are not rendered by default.

‎src/viam/gen/app/v1/app_pb2.pyi‎

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4792,13 +4792,15 @@ global___GetAppContentRequest = GetAppContentRequest
47924792
@typing.final
47934793
class GetAppContentResponse(google.protobuf.message.Message):
47944794
DESCRIPTOR: google.protobuf.descriptor.Descriptor
4795-
URL_FIELD_NUMBER: builtins.int
4796-
url: builtins.str
4795+
BLOB_PATH_FIELD_NUMBER: builtins.int
4796+
ENTRYPOINT_FIELD_NUMBER: builtins.int
4797+
blob_path: builtins.str
4798+
entrypoint: builtins.str
47974799

4798-
def __init__(self, *, url: builtins.str=...) -> None:
4800+
def __init__(self, *, blob_path: builtins.str=..., entrypoint: builtins.str=...) -> None:
47994801
...
48004802

4801-
def ClearField(self, field_name: typing.Literal['url', b'url']) -> None:
4803+
def ClearField(self, field_name: typing.Literal['blob_path', b'blob_path', 'entrypoint', b'entrypoint']) -> None:
48024804
...
48034805
global___GetAppContentResponse = GetAppContentResponse
48044806

‎src/viam/version_metadata.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
__version__ = "0.43.0"
22

3-
API_VERSION = "v0.1.411"
3+
API_VERSION = "v0.1.413"
44
SDK_VERSION = __version__

0 commit comments

Comments
 (0)