Formatting: Format all python code with black.
This CL is probably not what you're looking for, it's only
automated formatting. Ignore it with
`git blame --ignore-rev <revision>` for this commit.
BUG=b:233893248
TEST=CQ
Change-Id: I66591d7a738d241aed3290138c0f68065ab10a6d
Reviewed-on: https://chromium-review.googlesource.com/c/chromiumos/chromite/+/3879174
Reviewed-by: Mike Frysinger <vapier@chromium.org>
Tested-by: Alex Klein <saklein@chromium.org>
diff --git a/scripts/sysmon/system_metrics.py b/scripts/sysmon/system_metrics.py
index 2cafde5..b88b862 100644
--- a/scripts/sysmon/system_metrics.py
+++ b/scripts/sysmon/system_metrics.py
@@ -20,56 +20,61 @@
_cpu_count_metric = metrics.GaugeMetric(
- 'dev/cpu/count',
- description='Number of CPU cores.')
+ "dev/cpu/count", description="Number of CPU cores."
+)
_cpu_time_metric = metrics.FloatMetric(
- 'dev/cpu/time',
- description='percentage of time spent by the CPU '
- 'in different states.')
+ "dev/cpu/time",
+ description="percentage of time spent by the CPU " "in different states.",
+)
_disk_free_metric = metrics.GaugeMetric(
- 'dev/disk/free',
- description='Available bytes on disk partition.')
+ "dev/disk/free", description="Available bytes on disk partition."
+)
_disk_total_metric = metrics.GaugeMetric(
- 'dev/disk/total',
- description='Total bytes on disk partition.')
+ "dev/disk/total", description="Total bytes on disk partition."
+)
_inodes_free_metric = metrics.GaugeMetric(
- 'dev/inodes/free',
- description='Number of available inodes on '
- 'disk partition (unix only).')
+ "dev/inodes/free",
+ description="Number of available inodes on " "disk partition (unix only).",
+)
_inodes_total_metric = metrics.GaugeMetric(
- 'dev/inodes/total',
- description='Number of possible inodes on '
- 'disk partition (unix only)')
+ "dev/inodes/total",
+ description="Number of possible inodes on " "disk partition (unix only)",
+)
_mem_free_metric = metrics.GaugeMetric(
- 'dev/mem/free',
- description='Amount of memory available to a '
- 'process (in Bytes). Buffers are considered '
- 'free memory.')
+ "dev/mem/free",
+ description="Amount of memory available to a "
+ "process (in Bytes). Buffers are considered "
+ "free memory.",
+)
_mem_total_metric = metrics.GaugeMetric(
- 'dev/mem/total',
- description='Total physical memory in Bytes.')
+ "dev/mem/total", description="Total physical memory in Bytes."
+)
_BOOT_TIME = psutil.boot_time()
_disk_read_metric = metrics.CounterMetric(
- 'dev/disk/read', start_time=_BOOT_TIME,
- description='Number of Bytes read on disk.')
+ "dev/disk/read",
+ start_time=_BOOT_TIME,
+ description="Number of Bytes read on disk.",
+)
_disk_write_metric = metrics.CounterMetric(
- 'dev/disk/write', start_time=_BOOT_TIME,
- description='Number of Bytes written on disk.')
+ "dev/disk/write",
+ start_time=_BOOT_TIME,
+ description="Number of Bytes written on disk.",
+)
_uptime_metric = metrics.GaugeMetric(
- 'dev/uptime',
- description='Machine uptime, in seconds.')
+ "dev/uptime", description="Machine uptime, in seconds."
+)
_load_average_metric = metrics.FloatMetric(
- 'dev/proc/load_average',
- description='Number of processes currently '
- 'in the system run queue.')
+ "dev/proc/load_average",
+ description="Number of processes currently " "in the system run queue.",
+)
# ts_mon pipeline uses backend clocks when assigning timestamps to metric
# points. By comparing point timestamp to the point value (i.e. time by
@@ -78,112 +83,113 @@
#
# It is important to gather this metric right before the flush.
_unix_time_metric = metrics.GaugeMetric(
- 'dev/unix_time',
- description='Number of milliseconds since epoch'
- ' based on local machine clock.')
+ "dev/unix_time",
+ description="Number of milliseconds since epoch"
+ " based on local machine clock.",
+)
_os_name_metric = metrics.StringMetric(
- 'proc/os/name',
- description='OS name on the machine')
+ "proc/os/name", description="OS name on the machine"
+)
_os_version_metric = metrics.StringMetric(
- 'proc/os/version',
- description='OS version on the machine')
+ "proc/os/version", description="OS version on the machine"
+)
_os_arch_metric = metrics.StringMetric(
- 'proc/os/arch',
- description='OS architecture on this machine')
+ "proc/os/arch", description="OS architecture on this machine"
+)
_python_arch_metric = metrics.StringMetric(
- 'proc/python/arch',
- description='python userland '
- 'architecture on this machine')
+ "proc/python/arch",
+ description="python userland " "architecture on this machine",
+)
def collect_uptime():
- _uptime_metric.set(int(time.time() - _BOOT_TIME))
+ _uptime_metric.set(int(time.time() - _BOOT_TIME))
def collect_cpu_info():
- _cpu_count_metric.set(psutil.cpu_count())
+ _cpu_count_metric.set(psutil.cpu_count())
- times = psutil.cpu_times_percent()
- for mode in ('user', 'system', 'idle'):
- _cpu_time_metric.set(getattr(times, mode), {'mode': mode})
+ times = psutil.cpu_times_percent()
+ for mode in ("user", "system", "idle"):
+ _cpu_time_metric.set(getattr(times, mode), {"mode": mode})
def collect_disk_info(mountpoints=None):
- if mountpoints is None:
- mountpoints = [disk.mountpoint for disk in psutil.disk_partitions()]
- for mountpoint in mountpoints:
- _collect_disk_info_single(mountpoint)
- _collect_fs_inode_info(mountpoint)
- _collect_disk_io_info()
+ if mountpoints is None:
+ mountpoints = [disk.mountpoint for disk in psutil.disk_partitions()]
+ for mountpoint in mountpoints:
+ _collect_disk_info_single(mountpoint)
+ _collect_fs_inode_info(mountpoint)
+ _collect_disk_io_info()
def _collect_disk_info_single(mountpoint):
- fields = {'path': mountpoint}
+ fields = {"path": mountpoint}
- try:
- usage = psutil.disk_usage(mountpoint)
- except OSError as ex:
- if ex.errno == errno.ENOENT:
- # This happens on Windows when querying a removable drive that
- # doesn't have any media inserted right now.
- pass
+ try:
+ usage = psutil.disk_usage(mountpoint)
+ except OSError as ex:
+ if ex.errno == errno.ENOENT:
+ # This happens on Windows when querying a removable drive that
+ # doesn't have any media inserted right now.
+ pass
+ else:
+ raise
else:
- raise
- else:
- _disk_free_metric.set(usage.free, fields=fields)
- _disk_total_metric.set(usage.total, fields=fields)
+ _disk_free_metric.set(usage.free, fields=fields)
+ _disk_total_metric.set(usage.total, fields=fields)
- # inode counts are only available on Unix.
- if os.name == 'posix':
- _collect_fs_inode_info(mountpoint)
+ # inode counts are only available on Unix.
+ if os.name == "posix":
+ _collect_fs_inode_info(mountpoint)
def _collect_fs_inode_info(mountpoint):
- fields = {'path': mountpoint}
- stats = os.statvfs(mountpoint)
- _inodes_free_metric.set(stats.f_favail, fields=fields)
- _inodes_total_metric.set(stats.f_files, fields=fields)
+ fields = {"path": mountpoint}
+ stats = os.statvfs(mountpoint)
+ _inodes_free_metric.set(stats.f_favail, fields=fields)
+ _inodes_total_metric.set(stats.f_files, fields=fields)
def _collect_disk_io_info():
- try:
- # pylint: disable=dict-items-not-iterating
- disk_counters = psutil.disk_io_counters(perdisk=True).items()
- except RuntimeError as ex:
- if "couldn't find any physical disk" in str(ex):
- # Disk performance counters aren't enabled on Windows.
- pass
+ try:
+ # pylint: disable=dict-items-not-iterating
+ disk_counters = psutil.disk_io_counters(perdisk=True).items()
+ except RuntimeError as ex:
+ if "couldn't find any physical disk" in str(ex):
+ # Disk performance counters aren't enabled on Windows.
+ pass
+ else:
+ raise
else:
- raise
- else:
- for disk, counters in disk_counters:
- fields = {'disk': disk}
- _disk_read_metric.set(counters.read_bytes, fields=fields)
- _disk_write_metric.set(counters.write_bytes, fields=fields)
+ for disk, counters in disk_counters:
+ fields = {"disk": disk}
+ _disk_read_metric.set(counters.read_bytes, fields=fields)
+ _disk_write_metric.set(counters.write_bytes, fields=fields)
def collect_mem_info():
- # We don't report mem.used because (due to virtual memory) it is not
- # useful.
- mem = psutil.virtual_memory()
- _mem_free_metric.set(mem.available)
- _mem_total_metric.set(mem.total)
+ # We don't report mem.used because (due to virtual memory) it is not
+ # useful.
+ mem = psutil.virtual_memory()
+ _mem_free_metric.set(mem.available)
+ _mem_total_metric.set(mem.total)
def collect_load_avg():
- try:
- avg1, avg5, avg15 = os.getloadavg()
- except OSError:
- pass
- else:
- _load_average_metric.set(avg1, fields={'minutes': 1})
- _load_average_metric.set(avg5, fields={'minutes': 5})
- _load_average_metric.set(avg15, fields={'minutes': 15})
+ try:
+ avg1, avg5, avg15 = os.getloadavg()
+ except OSError:
+ pass
+ else:
+ _load_average_metric.set(avg1, fields={"minutes": 1})
+ _load_average_metric.set(avg5, fields={"minutes": 5})
+ _load_average_metric.set(avg15, fields={"minutes": 15})
def collect_unix_time():
- _unix_time_metric.set(int(time.time() * 1000))
+ _unix_time_metric.set(int(time.time() * 1000))