pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

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

incr_update_backup
Tyler Goodlet 2022-03-07 11:16:12 -05:00
parent fa0be47d66
commit 96ec4ba28b
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
piker/data/marketstore.py
View File

@ -222,7 +222,6 @@ class Storage:
''' '''
High level storage api for both real-time and historical ingest. High level storage api for both real-time and historical ingest.
''' '''
def __init__( def __init__(
self, self,
@ -284,10 +283,7 @@ class Storage:
tf_in_1s.inverse[data_set.timeframe] tf_in_1s.inverse[data_set.timeframe]
] = data_set.array ] = data_set.array
return ( return arrays[fqsn][timeframe] if timeframe else arrays
client,
arrays[fqsn][timeframe] if timeframe else arrays,
)
@acm @acm
@ -406,7 +402,8 @@ async def backfill_history_diff(
len(to_append), len(to_append),
dtype=mkts_dt, 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[[ mkts_array[:] = to_append[[
'time', 'time',
'open', 'open',