Automated Protos Update (#505)

Author: github-actions[bot]

Makefile

@@ -8,8 +8,8 @@ lint:
 	poetry run $(MAKE) _lint
 
 _format:
-	black --exclude ".*/gen/.*" ./src
-	isort ./src
+	black --exclude ".*/gen/.*" ./src ./tests ./docs/examples
+	isort ./src ./tests ./docs/examples
 
 format:
 	poetry run $(MAKE) _format

docs/examples/_server.py

@@ -31,6 +31,8 @@
     CreateOrganizationInviteResponse,
     CreateOrganizationRequest,
     CreateOrganizationResponse,
+    CreateRegistryItemRequest,
+    CreateRegistryItemResponse,
     CreateRobotPartSecretRequest,
     CreateRobotPartSecretResponse,
     DeleteFragmentRequest,
@@ -47,6 +49,8 @@
     DeleteOrganizationMemberResponse,
     DeleteOrganizationRequest,
     DeleteOrganizationResponse,
+    DeleteRegistryItemRequest,
+    DeleteRegistryItemResponse,
     DeleteRobotPartRequest,
     DeleteRobotPartResponse,
     DeleteRobotPartSecretRequest,
@@ -63,6 +67,8 @@
     GetOrganizationNamespaceAvailabilityResponse,
     GetOrganizationRequest,
     GetOrganizationResponse,
+    GetOrganizationsWithAccessToLocationRequest,
+    GetOrganizationsWithAccessToLocationResponse,
     GetRobotAPIKeysRequest,
     GetRobotAPIKeysResponse,
     GetRobotPartHistoryRequest,
@@ -95,19 +101,13 @@
     ListOrganizationsByUserResponse,
     ListOrganizationsRequest,
     ListOrganizationsResponse,
+    ListRegistryItemsRequest,
+    ListRegistryItemsResponse,
     ListRobotsRequest,
     ListRobotsResponse,
     Location,
     LocationAuthRequest,
     LocationAuthResponse,
-    CreateRegistryItemRequest,
-    CreateRegistryItemResponse,
-    GetOrganizationsWithAccessToLocationRequest,
-    GetOrganizationsWithAccessToLocationResponse,
-    ListRegistryItemsRequest,
-    ListRegistryItemsResponse,
-    UpdateRegistryItemRequest,
-    UpdateRegistryItemResponse,
 )
 from viam.proto.app import LogEntry as LogEntryPB
 from viam.proto.app import (
@@ -143,6 +143,8 @@
     UpdateOrganizationInviteAuthorizationsResponse,
     UpdateOrganizationRequest,
     UpdateOrganizationResponse,
+    UpdateRegistryItemRequest,
+    UpdateRegistryItemResponse,
     UpdateRobotPartRequest,
     UpdateRobotPartResponse,
     UpdateRobotRequest,
@@ -188,12 +190,12 @@
     TabularData,
     TabularDataByFilterRequest,
     TabularDataByFilterResponse,
-    TagsByFilterRequest,
-    TagsByFilterResponse,
     TabularDataByMQLRequest,
     TabularDataByMQLResponse,
     TabularDataBySQLRequest,
     TabularDataBySQLResponse,
+    TagsByFilterRequest,
+    TagsByFilterResponse,
 )
 from viam.proto.app.datasync import (
     DataCaptureUploadRequest,
@@ -586,6 +588,9 @@ async def ListRegistryItems(self, stream: Stream[ListRegistryItemsRequest, ListR
     async def UpdateRegistryItem(self, stream: Stream[UpdateRegistryItemRequest, UpdateRegistryItemResponse]) -> None:
         raise NotImplementedError()
 
+    async def DeleteRegistryItem(self, stream: Stream[DeleteRegistryItemRequest, DeleteRegistryItemResponse]) -> None:
+        raise NotImplementedError()
+
 
 async def main(*, host: str = "127.0.0.1", port: int = 9092) -> None:
     server = Server([MockData(), MockDataSync(), MockApp()])

docs/examples/example.ipynb

@@ -30,7 +30,8 @@
     "# Please excuse the boilerplate\n",
     "%autoawait asyncio\n",
     "import warnings\n",
-    "warnings.filterwarnings('ignore')"
+    "\n",
+    "warnings.filterwarnings(\"ignore\")"
    ]
   },
   {
@@ -47,12 +48,10 @@
     "from viam.robot.client import RobotClient\n",
     "from viam.rpc.dial import DialOptions\n",
     "\n",
+    "\n",
     "async def connect() -> RobotClient:\n",
-    "    options = RobotClient.Options(\n",
-    "        dial_options=DialOptions(insecure=True, disable_webrtc=True),\n",
-    "        log_level=logging.FATAL\n",
-    "    )\n",
-    "    return await RobotClient.at_address('localhost:9091', options)"
+    "    options = RobotClient.Options(dial_options=DialOptions(insecure=True, disable_webrtc=True), log_level=logging.FATAL)\n",
+    "    return await RobotClient.at_address(\"localhost:9091\", options)"
    ]
   },
   {
@@ -132,10 +131,12 @@
     "from viam.robot.client import RobotClient\n",
     "from viam.rpc.dial import DialOptions, dial\n",
     "\n",
+    "\n",
     "async def connect_with_channel() -> RobotClient:\n",
-    "    async with await dial('localhost:9091', DialOptions(insecure=True, disable_webrtc=True)) as channel:\n",
+    "    async with await dial(\"localhost:9091\", DialOptions(insecure=True, disable_webrtc=True)) as channel:\n",
     "        return await RobotClient.with_channel(channel, RobotClient.Options(refresh_interval=10, log_level=logging.FATAL))\n",
     "\n",
+    "\n",
     "robot = await connect_with_channel()\n",
     "print(robot.resource_names)\n",
     "await robot.close()"
@@ -167,7 +168,7 @@
     "image.save(\"foo.png\")\n",
     "\n",
     "# Don't forget to close the robot when you're done!\n",
-    "await robot.close()\n"
+    "await robot.close()"
    ]
   },
   {
@@ -210,6 +211,7 @@
    "source": [
     "from viam.services.vision import VisionClient\n",
     "\n",
+    "\n",
     "async def vision():\n",
     "    robot = await connect_with_channel()\n",
     "    vision = VisionClient.from_robot(robot)\n",
@@ -884,13 +886,14 @@
     "from pygments.lexers import PythonLexer\n",
     "from pygments.formatters import HtmlFormatter\n",
     "import IPython\n",
-    "with open('my_cool_arm.py') as f:\n",
+    "\n",
+    "with open(\"my_cool_arm.py\") as f:\n",
     "    code = f.read()\n",
     "\n",
     "formatter = HtmlFormatter()\n",
-    "IPython.display.HTML('<style type=\"text/css\">{}</style>{}'.format(\n",
-    "    formatter.get_style_defs('.highlight'),\n",
-    "    highlight(code, PythonLexer(), formatter)))"
+    "IPython.display.HTML(\n",
+    "    '<style type=\"text/css\">{}</style>{}'.format(formatter.get_style_defs(\".highlight\"), highlight(code, PythonLexer(), formatter))\n",
+    ")"
    ]
   },
   {
@@ -938,11 +941,13 @@
     "\n",
     "from my_cool_arm import MyCoolArm\n",
     "\n",
+    "\n",
     "async def main():\n",
-    "    srv = Server([MyCoolArm('my-arm')])\n",
+    "    srv = Server([MyCoolArm(\"my-arm\")])\n",
     "    await srv.serve()\n",
     "\n",
-    "if __name__ == '__main__':\n",
+    "\n",
+    "if __name__ == \"__main__\":\n",
     "    try:\n",
     "        asyncio.run(main())\n",
     "    except:\n",
@@ -1124,7 +1129,7 @@
    "source": [
     "from IPython.core.display import display, Image\n",
     "\n",
-    "display(Image(filename='./codediff.png'))"
+    "display(Image(filename=\"./codediff.png\"))"
    ]
   },
   {
@@ -1160,8 +1165,9 @@
     "from viam.rpc.dial import DialOptions, Credentials\n",
     "from viam.app.viam_client import ViamClient\n",
     "\n",
+    "\n",
     "async def connect() -> ViamClient:\n",
-    "    dial_options = DialOptions.with_api_key(api_key='<API_KEY>', api_key_id='<API_KEY_ID>')\n",
+    "    dial_options = DialOptions.with_api_key(api_key=\"<API_KEY>\", api_key_id=\"<API_KEY_ID>\")\n",
     "    return await ViamClient.create_from_dial_options(dial_options)"
    ]
   },
@@ -1191,6 +1197,7 @@
     "from viam.app.app_client import AppClient\n",
     "from viam.rpc.dial import _dial_direct\n",
     "\n",
+    "\n",
     "class MockViamClient:\n",
     "    @classmethod\n",
     "    async def create_viam_client(cls) -> Self:\n",
@@ -1199,15 +1206,16 @@
     "        self.data_client = DataClient(channel=self._channel, metadata={})\n",
     "        self.app_client = AppClient(channel=self._channel, metadata={})\n",
     "        return self\n",
-    "    \n",
+    "\n",
     "    _channel: Channel\n",
     "    data_client: DataClient\n",
     "    app_client: AppClient\n",
     "\n",
     "    def close(self):\n",
     "        self._channel.close()\n",
     "\n",
-    "viam_client = await MockViamClient.create_viam_client()\n"
+    "\n",
+    "viam_client = await MockViamClient.create_viam_client()"
    ]
   },
   {
@@ -1260,10 +1268,7 @@
     "from datetime import datetime\n",
     "\n",
     "left_motor_filter = data_client.create_filter(\n",
-    "    component_name=\"left_motor\",\n",
-    "    start_time=datetime(2023, 6, 5, 11),\n",
-    "    end_time=datetime(2023, 6, 5, 13, 30),\n",
-    "    tags=[\"speed_test_run\"]\n",
+    "    component_name=\"left_motor\", start_time=datetime(2023, 6, 5, 11), end_time=datetime(2023, 6, 5, 13, 30), tags=[\"speed_test_run\"]\n",
     ")\n",
     "\n",
     "data = await data_client.tabular_data_by_filter(filter=left_motor_filter)\n",
@@ -1290,14 +1295,14 @@
     "time_received_1 = datetime(2023, 6, 5, 11, 0, 3)\n",
     "\n",
     "await data_client.tabular_data_capture_upload(\n",
-    "    part_id=\"<ID>\", # Unique ID of the relevant robot part.\n",
-    "    component_type='rdk:component:motor',\n",
-    "    component_name='left_motor',\n",
-    "    method_name='IsPowered',\n",
+    "    part_id=\"<ID>\",  # Unique ID of the relevant robot part.\n",
+    "    component_type=\"rdk:component:motor\",\n",
+    "    component_name=\"left_motor\",\n",
+    "    method_name=\"IsPowered\",\n",
     "    method_parameters=None,\n",
     "    tags=[\"tag_1\", \"tag_2\"],\n",
     "    data_request_times=[(time_requested_1, time_received_1)],\n",
-    "    tabular_data=[{'PowerPCT': 0, 'IsPowered': False}]\n",
+    "    tabular_data=[{\"PowerPCT\": 0, \"IsPowered\": False}],\n",
     ")"
    ]
   },
@@ -1353,7 +1358,7 @@
     "for location in my_locations:\n",
     "    more_robots = await app_client.list_robots(location_id=location.id)\n",
     "    robots += more_robots\n",
-    "    \n",
+    "\n",
     "for robot in robots:\n",
     "    print(robot.name)"
    ]
@@ -1439,7 +1444,7 @@
     "assert logs[0].caller is not None\n",
     "for item in logs[0].caller.items():\n",
     "    print(f\"{item[0]}: {item[1]}\")\n",
-    "    \n",
+    "\n",
     "print(f\"\\n*****PROTO*****\\n\")\n",
     "print(logs[0].proto.caller)"
    ]

docs/examples/module_step2.py

@@ -1,6 +1,7 @@
 # wifi-sensor/src/wifi_sensor_module.py
 import asyncio
 from typing import Any, ClassVar, Dict, Mapping, Optional
+
 from typing_extensions import Self
 
 from viam.components.sensor import Sensor

docs/examples/module_step2_optional.py

@@ -1,6 +1,7 @@
 # wifi-sensor/src/wifi_sensor_module.py
 import asyncio
 from typing import Any, ClassVar, Dict, Mapping, Optional, Sequence
+
 from typing_extensions import Self
 
 from viam.components.sensor import Sensor

docs/examples/module_step3.py

@@ -1,6 +1,7 @@
 # wifi-sensor/src/wifi_sensor_module.py
 import asyncio
 from typing import Any, ClassVar, Dict, Mapping, Optional
+
 from typing_extensions import Self
 
 from viam.components.sensor import Sensor