Implement gcloud_producer for bm-tools

bm-tools works via "Machine" objects, which are front
objects for actual virtual or physical machines. glcoud_producer
produces machines on GCP using the `gcloud` tool.

Included are:
- GCloudProducer - the class producing machines
- MockGCloudProducer - class for mocking GCloudProducer.
- tests using the mock
- test data as .json files. Code to generate this test data may be
included in a follow up.

PiperOrigin-RevId: 289005958
This commit is contained in:
Zach Koopmans
2020-01-09 17:24:35 -08:00
committed by gVisor bot
parent 26c5653bb5
commit f1b69b159f
8 changed files with 721 additions and 2 deletions
+1
View File
@@ -5,5 +5,6 @@ py_binary(
srcs = ["run.py"],
main = "run.py",
python_version = "PY3",
srcs_version = "PY3",
deps = ["//benchmarks/runner"],
)
+4 -1
View File
@@ -24,6 +24,7 @@ py_library(
name = "container",
srcs = ["container.py"],
deps = [
"//benchmarks/workloads",
requirement("asn1crypto", False),
requirement("chardet", False),
requirement("certifi", False),
@@ -45,6 +46,7 @@ py_library(
"//benchmarks/harness:container",
"//benchmarks/harness:ssh_connection",
"//benchmarks/harness:tunnel_dispatcher",
"//benchmarks/harness/machine_mocks",
requirement("asn1crypto", False),
requirement("chardet", False),
requirement("certifi", False),
@@ -53,6 +55,7 @@ py_library(
requirement("idna", False),
requirement("ptyprocess", False),
requirement("requests", False),
requirement("six", False),
requirement("urllib3", False),
requirement("websocket-client", False),
],
@@ -64,7 +67,7 @@ py_library(
deps = [
"//benchmarks/harness",
requirement("bcrypt", False),
requirement("cffi", False),
requirement("cffi", True),
requirement("paramiko", True),
requirement("cryptography", False),
],
@@ -20,6 +20,7 @@ py_library(
srcs = ["mock_producer.py"],
deps = [
"//benchmarks/harness:machine",
"//benchmarks/harness/machine_producers:gcloud_producer",
"//benchmarks/harness/machine_producers:machine_producer",
],
)
@@ -38,3 +39,42 @@ py_library(
name = "gcloud_mock_recorder",
srcs = ["gcloud_mock_recorder.py"],
)
py_library(
name = "gcloud_producer",
srcs = ["gcloud_producer.py"],
deps = [
"//benchmarks/harness:machine",
"//benchmarks/harness/machine_producers:gcloud_mock_recorder",
"//benchmarks/harness/machine_producers:machine_producer",
],
)
filegroup(
name = "test_data",
srcs = [
"testdata/get_five.json",
"testdata/get_one.json",
],
)
py_library(
name = "gcloud_producer_test_lib",
srcs = ["gcloud_producer_test.py"],
deps = [
"//benchmarks/harness/machine_producers:machine_producer",
"//benchmarks/harness/machine_producers:mock_producer",
],
)
py_test(
name = "gcloud_producer_test",
srcs = [":gcloud_producer_test_lib"],
data = [
":test_data",
],
python_version = "PY3",
tags = [
"local",
],
)
@@ -0,0 +1,250 @@
# python3
# Copyright 2019 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
"""A machine producer which produces machine objects using `gcloud`.
Machine producers produce valid harness.Machine objects which are backed by
real machines. This producer produces those machines on the given user's GCP
account using the `gcloud` tool.
GCloudProducer creates instances on the given GCP account named like:
`machine-XXXXXXX-XXXX-XXXX-XXXXXXXXXXXX` in a randomized fashion such that name
collisions with user instances shouldn't happen.
Typical usage example:
producer = GCloudProducer(args)
machines = producer.get_machines(NUM_MACHINES)
# run stuff on machines with machines[i].run(CMD)
producer.release_machines(NUM_MACHINES)
"""
import datetime
import getpass
import json
import subprocess
import threading
from typing import List, Dict, Any
import uuid
from benchmarks.harness import machine
from benchmarks.harness.machine_producers import gcloud_mock_recorder
from benchmarks.harness.machine_producers import machine_producer
DEFAULT_USER = getpass.getuser()
class GCloudProducer(machine_producer.MachineProducer):
"""Implementation of MachineProducer backed by GCP.
Produces Machine objects backed by GCP instances.
Attributes:
project: The GCP project name under which to create the machines.
ssh_key_path: path to a valid ssh key. See README on vaild ssh keys.
image: image name as a string.
image_project: image project as a string.
zone: string to a valid GCP zone.
ssh_user: string of user name for ssh_key
ssh_password: string of password for ssh key
mock: a mock printer which will print mock data if required. Mock data is
recorded output from subprocess calls (returncode, stdout, args).
condition: mutex for this class around machine creation and deleteion.
"""
def __init__(self,
project: str,
ssh_key_path: str,
image: str,
image_project: str,
zone: str,
ssh_user: str,
mock: gcloud_mock_recorder.MockPrinter = None):
self.project = project
self.ssh_key_path = ssh_key_path
self.image = image
self.image_project = image_project
self.zone = zone
self.ssh_user = ssh_user if ssh_user else DEFAULT_USER
self.mock = mock
self.condition = threading.Condition()
def get_machines(self, num_machines: int) -> List[machine.Machine]:
"""Returns requested number of machines backed by GCP instances."""
if num_machines <= 0:
raise ValueError(
"Cannot ask for {num} machines!".format(num=num_machines))
with self.condition:
names = self._get_unique_names(num_machines)
self._build_instances(names)
instances = self._start_command(names)
self._add_ssh_key_to_instances(names)
return self._machines_from_instances(instances)
def release_machines(self, machine_list: List[machine.Machine]):
"""Releases the requested number of machines, deleting the instances."""
if not machine_list:
return
with self.condition:
cmd = "gcloud compute instances delete --quiet".split(" ")
names = [str(m) for m in machine_list]
cmd.extend(names)
cmd.append("--zone={zone}".format(zone=self.zone))
self._run_command(cmd)
def _machines_from_instances(
self, instances: List[Dict[str, Any]]) -> List[machine.Machine]:
"""Creates Machine Objects from json data describing created instances."""
machines = []
for instance in instances:
name = instance["name"]
kwargs = {
"hostname":
instance["networkInterfaces"][0]["accessConfigs"][0]["natIP"],
"key_path":
self.ssh_key_path,
"username":
self.ssh_user
}
machines.append(machine.RemoteMachine(name=name, **kwargs))
return machines
def _get_unique_names(self, num_names) -> List[str]:
"""Returns num_names unique names based on data from the GCP project."""
curr_machines = self._list_machines()
curr_names = set([machine["name"] for machine in curr_machines])
ret = []
while len(ret) < num_names:
new_name = "machine-" + str(uuid.uuid4())
if new_name not in curr_names:
ret.append(new_name)
curr_names.update(new_name)
return ret
def _build_instances(self, names: List[str]) -> List[Dict[str, Any]]:
"""Creates instances using gcloud command.
Runs the command `gcloud compute instances create` and returns json data
on created instances on success. Creates len(names) instances, one for each
name.
Args:
names: list of names of instances to create.
Returns:
List of json data describing created machines.
"""
if not names:
raise ValueError(
"_build_instances cannot create instances without names.")
cmd = "gcloud compute instances create".split(" ")
cmd.extend(names)
cmd.extend("--preemptible --image={image} --zone={zone}".format(
image=self.image, zone=self.zone).split(" "))
if self.image_project:
cmd.append("--image-project={project}".format(project=self.image_project))
res = self._run_command(cmd)
return json.loads(res.stdout)
def _start_command(self, names):
"""Starts instances using gcloud command.
Runs the command `gcloud compute instances start` on list of instances by
name and returns json data on started instances on success.
Args:
names: list of names of instances to start.
Returns:
List of json data describing started machines.
"""
if not names:
raise ValueError("_start_command cannot start empty instance list.")
cmd = "gcloud compute instances start".split(" ")
cmd.extend(names)
cmd.append("--zone={zone}".format(zone=self.zone))
cmd.append("--project={project}".format(project=self.project))
res = self._run_command(cmd)
return json.loads(res.stdout)
def _add_ssh_key_to_instances(self, names: List[str]) -> None:
"""Adds ssh key to instances by calling gcloud ssh command.
Runs the command `gcloud compute ssh instance_name` on list of images by
name. Tries to ssh into given instance
Args:
names: list of machine names to which to add the ssh-key
self.ssh_key_path.
Raises:
subprocess.CalledProcessError: when underlying subprocess call returns an
error other than 255 (Connection closed by remote host).
TimeoutError: when 3 unsuccessful tries to ssh into the host return 255.
"""
for name in names:
cmd = "gcloud compute ssh {name}".format(name=name).split(" ")
cmd.append("--ssh-key-file={key}".format(key=self.ssh_key_path))
cmd.append("--zone={zone}".format(zone=self.zone))
cmd.append("--command=uname")
timeout = datetime.timedelta(seconds=5 * 60)
start = datetime.datetime.now()
while datetime.datetime.now() <= timeout + start:
try:
self._run_command(cmd)
break
except subprocess.CalledProcessError as e:
if datetime.datetime.now() > timeout + start:
raise TimeoutError(
"Could not SSH into instance after 5 min: {name}".format(
name=name))
# 255 is the returncode for ssh connection refused.
elif e.returncode == 255:
continue
else:
raise e
def _list_machines(self) -> List[Dict[str, Any]]:
"""Runs `list` gcloud command and returns list of Machine data."""
cmd = "gcloud compute instances list --project {project}".format(
project=self.project).split(" ")
res = self._run_command(cmd)
return json.loads(res.stdout)
def _run_command(self, cmd: List[str]) -> subprocess.CompletedProcess:
"""Runs command as a subprocess.
Runs command as subprocess and returns the result.
If this has a mock recorder, use the record method to record the subprocess
call.
Args:
cmd: command to be run as a list of strings.
Returns:
Completed process object to be parsed by caller.
Raises:
CalledProcessError: if subprocess.run returns an error.
"""
cmd = cmd + ["--format=json"]
res = subprocess.run(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
if self.mock:
self.mock.record(res)
if res.returncode != 0:
raise subprocess.CalledProcessError(
cmd=res.args,
output=res.stdout,
stderr=res.stderr,
returncode=res.returncode)
return res
@@ -0,0 +1,48 @@
# python3
# Copyright 2019 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
"""Tests GCloudProducer using mock data.
GCloudProducer produces machines using 'get_machines' and 'release_machines'
methods. The tests check recorded data (jsonified subprocess.CompletedProcess
objects) of the producer producing one and five machines.
"""
import os
import types
from benchmarks.harness.machine_producers import machine_producer
from benchmarks.harness.machine_producers import mock_producer
TEST_DIR = os.path.dirname(__file__)
def run_get_release(producer: machine_producer.MachineProducer,
num_machines: int,
validator: types.FunctionType = None):
machines = producer.get_machines(num_machines)
assert len(machines) == num_machines
if validator:
validator(machines=machines, cmd="uname -a", workload=None)
producer.release_machines(machines)
def test_run_one():
mock = mock_producer.MockReader(TEST_DIR + "get_one.json")
producer = mock_producer.MockGCloudProducer(mock)
run_get_release(producer, 1)
def test_run_five():
mock = mock_producer.MockReader(TEST_DIR + "get_five.json")
producer = mock_producer.MockGCloudProducer(mock)
run_get_release(producer, 5)
@@ -13,9 +13,11 @@
# limitations under the License.
"""Producers of mocks."""
from typing import List
from typing import List, Any
from benchmarks.harness import machine
from benchmarks.harness.machine_producers import gcloud_mock_recorder
from benchmarks.harness.machine_producers import gcloud_producer
from benchmarks.harness.machine_producers import machine_producer
@@ -29,3 +31,22 @@ class MockMachineProducer(machine_producer.MachineProducer):
def release_machines(self, machine_list: List[machine.MockMachine]):
"""No-op."""
return
class MockGCloudProducer(gcloud_producer.GCloudProducer):
"""Mocks GCloudProducer for testing purposes."""
def __init__(self, mock: gcloud_mock_recorder.MockReader, **kwargs):
gcloud_producer.GCloudProducer.__init__(
self, project="mock", ssh_private_key_path="mock", **kwargs)
self.mock = mock
def _validate_ssh_file(self):
pass
def _run_command(self, cmd):
return self.mock.pop(cmd)
def _machines_from_instances(
self, instances: List[Any]) -> List[machine.MockMachine]:
return [machine.MockMachine() for _ in instances]
@@ -0,0 +1,211 @@
[
{
"args": [
"gcloud",
"compute",
"instances",
"list",
"--project",
"project",
"--format=json"
],
"stdout": "[{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":{\"natIP\":\"0.0.0.0\"}]}]}]",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"instances",
"create",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"machine-5f28f145-cc2d-427d-9cbf-428d164cdb92",
"machine-da5859b5-bae6-435d-8005-0202d6f6e065",
"machine-880a8a2f-918c-4f9e-a43c-ed3c8e02ea05",
"machine-1149147d-71e2-43ea-8fe1-49256e5c441c",
"--preemptible",
"--image=ubuntu-1910-eoan-v20191204",
"--zone=us-west1-b",
"--image-project=ubuntu-os-cloud",
"--format=json"
],
"stdout": "[{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]}]",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"instances",
"start",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"machine-5f28f145-cc2d-427d-9cbf-428d164cdb92",
"machine-da5859b5-bae6-435d-8005-0202d6f6e065",
"machine-880a8a2f-918c-4f9e-a43c-ed3c8e02ea05",
"machine-1149147d-71e2-43ea-8fe1-49256e5c441c",
"--zone=us-west1-b",
"--project=project",
"--format=json"
],
"stdout": "[{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]},{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]}]",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "Linux\n[]\n",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-5f28f145-cc2d-427d-9cbf-428d164cdb92",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "Linux\n[]\n",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-da5859b5-bae6-435d-8005-0202d6f6e065",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "Linux\n[]\n",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-880a8a2f-918c-4f9e-a43c-ed3c8e02ea05",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "Linux\n[]\n",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-1149147d-71e2-43ea-8fe1-49256e5c441c",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "Linux\n[]\n",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"instances",
"delete",
"--quiet",
"machine-42c9bf6e-8d45-4c37-b1c0-7e4fdcf530fc",
"machine-5f28f145-cc2d-427d-9cbf-428d164cdb92",
"machine-da5859b5-bae6-435d-8005-0202d6f6e065",
"machine-880a8a2f-918c-4f9e-a43c-ed3c8e02ea05",
"machine-1149147d-71e2-43ea-8fe1-49256e5c441c",
"--zone=us-west1-b",
"--format=json"
],
"stdout": "[]\n",
"returncode": "0"
}
]
@@ -0,0 +1,145 @@
[
{
"args": [
"gcloud",
"compute",
"instances",
"list",
"--project",
"linux-testing-user",
"--format=json"
],
"stdout": "[{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]}]",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"instances",
"create",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--preemptible",
"--image=ubuntu-1910-eoan-v20191204",
"--zone=us-west1-b",
"--image-project=ubuntu-os-cloud",
"--format=json"
],
"stdout": "[{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]}]",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"instances",
"start",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--zone=us-west1-b",
"--project=linux-testing-user",
"--format=json"
],
"stdout": "[{\"name\":\"name\", \"networkInterfaces\":[{\"accessConfigs\":[{\"natIP\":\"0.0.0.0\"}]}]}]",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "",
"returncode": "255"
},
{
"args": [
"gcloud",
"compute",
"ssh",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--ssh-key-file=/usr/local/google/home/user/.ssh/benchmark-tools",
"--zone=us-west1-b",
"--command=uname",
"--format=json"
],
"stdout": "Linux\n[]\n",
"returncode": "0"
},
{
"args": [
"gcloud",
"compute",
"instances",
"delete",
"--quiet",
"machine-129dfcf9-b05b-4c16-a4cd-21353b570ddc",
"--zone=us-west1-b",
"--format=json"
],
"stdout": "[]\n",
"returncode": "0"
}
]