Return all timeframe arrays if `timeframe` not passed as input

marketstore_backup
Tyler Goodlet 2022-03-07 11:16:12 -05:00
parent f7a0f117a0
commit 7f87d09bf0
1 changed files with 3 additions and 6 deletions

View File

@ -222,7 +222,6 @@ class Storage:
'''
High level storage api for both real-time and historical ingest.
'''
def __init__(
self,
@ -284,10 +283,7 @@ class Storage:
tf_in_1s.inverse[data_set.timeframe]
] = data_set.array
return (
client,
arrays[fqsn][timeframe] if timeframe else arrays,
)
return arrays[fqsn][timeframe] if timeframe else arrays
@acm
@ -406,7 +402,8 @@ async def backfill_history_diff(
len(to_append),
dtype=mkts_dt,
)
# copy from shm array
# copy from shm array (yes it's this easy):
# https://numpy.org/doc/stable/user/basics.rec.html#assignment-from-other-structured-arrays
mkts_array[:] = to_append[[
'time',
'open',