Skip to content

Commit 9ed3b0c

Browse files
viambotviambot
authored
Automated Protos Update (#876)
Co-authored-by: viambot <[email protected]>
1 parent c181037 commit 9ed3b0c

File tree

7 files changed

+279
-13
lines changed

7 files changed

+279
-13
lines changed

‎src/viam/app/viam_client.py‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,6 @@ async def create_from_env_vars(cls, dial_options: Optional[DialOptions] = None,
5656

5757
return await cls.create_from_dial_options(dial_options, app_url)
5858

59-
6059
@classmethod
6160
async def create_from_dial_options(cls, dial_options: DialOptions, app_url: Optional[str] = None) -> Self:
6261
"""Create `ViamClient` that establishes a connection to the Viam app.

‎src/viam/gen/app/data/v1/data_grpc.py‎

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

‎src/viam/gen/app/data/v1/data_pb2.py‎

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

‎src/viam/gen/app/data/v1/data_pb2.pyi‎

Lines changed: 184 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1421,4 +1421,187 @@ class RemoveBinaryDataFromDatasetByIDsResponse(google.protobuf.message.Message):
14211421

14221422
def __init__(self) -> None:
14231423
...
1424-
global___RemoveBinaryDataFromDatasetByIDsResponse = RemoveBinaryDataFromDatasetByIDsResponse
1424+
global___RemoveBinaryDataFromDatasetByIDsResponse = RemoveBinaryDataFromDatasetByIDsResponse
1425+
1426+
@typing.final
1427+
class DataPipeline(google.protobuf.message.Message):
1428+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1429+
ID_FIELD_NUMBER: builtins.int
1430+
ORGANIZATION_ID_FIELD_NUMBER: builtins.int
1431+
NAME_FIELD_NUMBER: builtins.int
1432+
MQL_BINARY_FIELD_NUMBER: builtins.int
1433+
SCHEDULE_FIELD_NUMBER: builtins.int
1434+
API_KEY_ID_FIELD_NUMBER: builtins.int
1435+
ENABLED_FIELD_NUMBER: builtins.int
1436+
id: builtins.str
1437+
organization_id: builtins.str
1438+
'The associated Viam organization ID.'
1439+
name: builtins.str
1440+
'A unique identifier at the org level.'
1441+
schedule: builtins.str
1442+
'A cron expression representing the expected execution schedule (note this also defines\n the input time window; an hourly schedule would process 1 hour of data at a time).\n '
1443+
api_key_id: builtins.str
1444+
'The API key ID to use when executing the pipeline.'
1445+
enabled: builtins.bool
1446+
'Whether or not the pipeline is enabled.'
1447+
1448+
@property
1449+
def mql_binary(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]:
1450+
"""A MongoDB aggregation pipeline as a list of BSON documents, where
1451+
each document is one stage in the pipeline.
1452+
"""
1453+
1454+
def __init__(self, *, id: builtins.str=..., organization_id: builtins.str=..., name: builtins.str=..., mql_binary: collections.abc.Iterable[builtins.bytes] | None=..., schedule: builtins.str=..., api_key_id: builtins.str=..., enabled: builtins.bool=...) -> None:
1455+
...
1456+
1457+
def ClearField(self, field_name: typing.Literal['api_key_id', b'api_key_id', 'enabled', b'enabled', 'id', b'id', 'mql_binary', b'mql_binary', 'name', b'name', 'organization_id', b'organization_id', 'schedule', b'schedule']) -> None:
1458+
...
1459+
global___DataPipeline = DataPipeline
1460+
1461+
@typing.final
1462+
class GetDataPipelineRequest(google.protobuf.message.Message):
1463+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1464+
ID_FIELD_NUMBER: builtins.int
1465+
id: builtins.str
1466+
1467+
def __init__(self, *, id: builtins.str=...) -> None:
1468+
...
1469+
1470+
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1471+
...
1472+
global___GetDataPipelineRequest = GetDataPipelineRequest
1473+
1474+
@typing.final
1475+
class GetDataPipelineResponse(google.protobuf.message.Message):
1476+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1477+
DATA_PIPELINE_FIELD_NUMBER: builtins.int
1478+
1479+
@property
1480+
def data_pipeline(self) -> global___DataPipeline:
1481+
...
1482+
1483+
def __init__(self, *, data_pipeline: global___DataPipeline | None=...) -> None:
1484+
...
1485+
1486+
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
1487+
...
1488+
1489+
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> None:
1490+
...
1491+
global___GetDataPipelineResponse = GetDataPipelineResponse
1492+
1493+
@typing.final
1494+
class ListDataPipelinesRequest(google.protobuf.message.Message):
1495+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1496+
ORGANIZATION_ID_FIELD_NUMBER: builtins.int
1497+
organization_id: builtins.str
1498+
1499+
def __init__(self, *, organization_id: builtins.str=...) -> None:
1500+
...
1501+
1502+
def ClearField(self, field_name: typing.Literal['organization_id', b'organization_id']) -> None:
1503+
...
1504+
global___ListDataPipelinesRequest = ListDataPipelinesRequest
1505+
1506+
@typing.final
1507+
class ListDataPipelinesResponse(google.protobuf.message.Message):
1508+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1509+
DATA_PIPELINES_FIELD_NUMBER: builtins.int
1510+
1511+
@property
1512+
def data_pipelines(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___DataPipeline]:
1513+
...
1514+
1515+
def __init__(self, *, data_pipelines: collections.abc.Iterable[global___DataPipeline] | None=...) -> None:
1516+
...
1517+
1518+
def ClearField(self, field_name: typing.Literal['data_pipelines', b'data_pipelines']) -> None:
1519+
...
1520+
global___ListDataPipelinesResponse = ListDataPipelinesResponse
1521+
1522+
@typing.final
1523+
class CreateDataPipelineRequest(google.protobuf.message.Message):
1524+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1525+
DATA_PIPELINE_FIELD_NUMBER: builtins.int
1526+
1527+
@property
1528+
def data_pipeline(self) -> global___DataPipeline:
1529+
...
1530+
1531+
def __init__(self, *, data_pipeline: global___DataPipeline | None=...) -> None:
1532+
...
1533+
1534+
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
1535+
...
1536+
1537+
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> None:
1538+
...
1539+
global___CreateDataPipelineRequest = CreateDataPipelineRequest
1540+
1541+
@typing.final
1542+
class CreateDataPipelineResponse(google.protobuf.message.Message):
1543+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1544+
ID_FIELD_NUMBER: builtins.int
1545+
id: builtins.str
1546+
1547+
def __init__(self, *, id: builtins.str=...) -> None:
1548+
...
1549+
1550+
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1551+
...
1552+
global___CreateDataPipelineResponse = CreateDataPipelineResponse
1553+
1554+
@typing.final
1555+
class UpdateDataPipelineRequest(google.protobuf.message.Message):
1556+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1557+
ID_FIELD_NUMBER: builtins.int
1558+
DATA_PIPELINE_FIELD_NUMBER: builtins.int
1559+
id: builtins.str
1560+
1561+
@property
1562+
def data_pipeline(self) -> global___DataPipeline:
1563+
...
1564+
1565+
def __init__(self, *, id: builtins.str=..., data_pipeline: global___DataPipeline | None=...) -> None:
1566+
...
1567+
1568+
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
1569+
...
1570+
1571+
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline', 'id', b'id']) -> None:
1572+
...
1573+
global___UpdateDataPipelineRequest = UpdateDataPipelineRequest
1574+
1575+
@typing.final
1576+
class UpdateDataPipelineResponse(google.protobuf.message.Message):
1577+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1578+
ID_FIELD_NUMBER: builtins.int
1579+
id: builtins.str
1580+
1581+
def __init__(self, *, id: builtins.str=...) -> None:
1582+
...
1583+
1584+
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1585+
...
1586+
global___UpdateDataPipelineResponse = UpdateDataPipelineResponse
1587+
1588+
@typing.final
1589+
class DeleteDataPipelineRequest(google.protobuf.message.Message):
1590+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1591+
ID_FIELD_NUMBER: builtins.int
1592+
id: builtins.str
1593+
1594+
def __init__(self, *, id: builtins.str=...) -> None:
1595+
...
1596+
1597+
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1598+
...
1599+
global___DeleteDataPipelineRequest = DeleteDataPipelineRequest
1600+
1601+
@typing.final
1602+
class DeleteDataPipelineResponse(google.protobuf.message.Message):
1603+
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1604+
1605+
def __init__(self) -> None:
1606+
...
1607+
global___DeleteDataPipelineResponse = DeleteDataPipelineResponse

‎src/viam/proto/app/data/__init__.py‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,20 +29,29 @@
2929
Classification,
3030
ConfigureDatabaseUserRequest,
3131
ConfigureDatabaseUserResponse,
32+
CreateDataPipelineRequest,
33+
CreateDataPipelineResponse,
34+
DataPipeline,
3235
DataRequest,
3336
DeleteBinaryDataByFilterRequest,
3437
DeleteBinaryDataByFilterResponse,
3538
DeleteBinaryDataByIDsRequest,
3639
DeleteBinaryDataByIDsResponse,
40+
DeleteDataPipelineRequest,
41+
DeleteDataPipelineResponse,
3742
DeleteTabularDataRequest,
3843
DeleteTabularDataResponse,
3944
ExportTabularDataRequest,
4045
ExportTabularDataResponse,
4146
Filter,
4247
GetDatabaseConnectionRequest,
4348
GetDatabaseConnectionResponse,
49+
GetDataPipelineRequest,
50+
GetDataPipelineResponse,
4451
GetLatestTabularDataRequest,
4552
GetLatestTabularDataResponse,
53+
ListDataPipelinesRequest,
54+
ListDataPipelinesResponse,
4655
Order,
4756
RemoveBinaryDataFromDatasetByIDsRequest,
4857
RemoveBinaryDataFromDatasetByIDsResponse,
@@ -65,6 +74,8 @@
6574
TagsFilterType,
6675
UpdateBoundingBoxRequest,
6776
UpdateBoundingBoxResponse,
77+
UpdateDataPipelineRequest,
78+
UpdateDataPipelineResponse,
6879
)
6980

7081
__all__ = [
@@ -95,20 +106,29 @@
95106
"Classification",
96107
"ConfigureDatabaseUserRequest",
97108
"ConfigureDatabaseUserResponse",
109+
"CreateDataPipelineRequest",
110+
"CreateDataPipelineResponse",
111+
"DataPipeline",
98112
"DataRequest",
99113
"DeleteBinaryDataByFilterRequest",
100114
"DeleteBinaryDataByFilterResponse",
101115
"DeleteBinaryDataByIDsRequest",
102116
"DeleteBinaryDataByIDsResponse",
117+
"DeleteDataPipelineRequest",
118+
"DeleteDataPipelineResponse",
103119
"DeleteTabularDataRequest",
104120
"DeleteTabularDataResponse",
105121
"ExportTabularDataRequest",
106122
"ExportTabularDataResponse",
107123
"Filter",
124+
"GetDataPipelineRequest",
125+
"GetDataPipelineResponse",
108126
"GetDatabaseConnectionRequest",
109127
"GetDatabaseConnectionResponse",
110128
"GetLatestTabularDataRequest",
111129
"GetLatestTabularDataResponse",
130+
"ListDataPipelinesRequest",
131+
"ListDataPipelinesResponse",
112132
"Order",
113133
"RemoveBinaryDataFromDatasetByIDsRequest",
114134
"RemoveBinaryDataFromDatasetByIDsResponse",
@@ -131,4 +151,6 @@
131151
"TagsFilterType",
132152
"UpdateBoundingBoxRequest",
133153
"UpdateBoundingBoxResponse",
154+
"UpdateDataPipelineRequest",
155+
"UpdateDataPipelineResponse",
134156
]

‎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.409"
3+
API_VERSION = "v0.1.410"
44
SDK_VERSION = __version__

‎tests/test_viam_client.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import random
21
import os
2+
import random
33
from unittest.mock import patch
44
from uuid import uuid4
55

0 commit comments

Comments
 (0)