From 44c339779f6573d8e1144fd563939ee4bad274c8 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 9 Oct 2025 20:00:05 -0400 Subject: [PATCH] `.storage.__init__`: code styling updates --- piker/storage/__init__.py | 20 ++++++++++++++------ 1 file changed, 14 insertions(+), 6 deletions(-) diff --git a/piker/storage/__init__.py b/piker/storage/__init__.py index c411cc4f..17cfd35f 100644 --- a/piker/storage/__init__.py +++ b/piker/storage/__init__.py @@ -43,7 +43,6 @@ from typing import ( import numpy as np - from .. import config from ..service import ( check_for_service, @@ -162,7 +161,10 @@ class StorageConnectionError(ConnectionError): ''' -def get_storagemod(name: str) -> ModuleType: +def get_storagemod( + name: str, + +) -> ModuleType: mod: ModuleType = import_module( '.' + name, 'piker.storage', @@ -175,9 +177,12 @@ def get_storagemod(name: str) -> ModuleType: @acm async def open_storage_client( - backend: str | None = None, + backend: str|None = None, -) -> tuple[ModuleType, StorageClient]: +) -> tuple[ + ModuleType, + StorageClient, +]: ''' Load the ``StorageClient`` for named backend. @@ -277,7 +282,10 @@ async def open_tsdb_client( from ..data.feed import maybe_open_feed async with ( - open_storage_client() as (_, storage), + open_storage_client() as ( + _, + storage, + ), maybe_open_feed( [fqme], @@ -285,7 +293,7 @@ async def open_tsdb_client( ) as feed, ): - profiler(f'opened feed for {fqme}') + profiler(f'opened feed for {fqme!r}') # to_append = feed.hist_shm.array # to_prepend = None