From bd23b6e8f251e396628145a073621be5b17deb81 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Fri, 29 Apr 2022 08:12:29 -0400 Subject: [PATCH] Add , indicates hist size to decrement to storage logic --- piker/brokers/_util.py | 23 +++++++++++++++++++---- 1 file changed, 19 insertions(+), 4 deletions(-) diff --git a/piker/brokers/_util.py b/piker/brokers/_util.py index 6fcf11f7..acd75d6c 100644 --- a/piker/brokers/_util.py +++ b/piker/brokers/_util.py @@ -33,7 +33,22 @@ class SymbolNotFound(BrokerError): class NoData(BrokerError): - "Symbol data not permitted" + ''' + Symbol data not permitted or no data + for time range found. + + ''' + def __init__( + self, + *args, + frame_size: int = 1000, + + ) -> None: + super().__init__(*args) + + # when raised, machinery can check if the backend + # set a "frame size" for doing datetime calcs. + self.frame_size: int = 1000 def resproc( @@ -50,12 +65,12 @@ def resproc( if not resp.status_code == 200: raise BrokerError(resp.body) try: - json = resp.json() + msg = resp.json() except json.decoder.JSONDecodeError: log.exception(f"Failed to process {resp}:\n{resp.text}") raise BrokerError(resp.text) if log_resp: - log.debug(f"Received json contents:\n{colorize_json(json)}") + log.debug(f"Received json contents:\n{colorize_json(msg)}") - return json if return_json else resp + return msg if return_json else resp