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

Use `code.interact()` in anal subcmd for now

basic_buy_bot
Tyler Goodlet 2023-06-08 10:24:42 -04:00
parent 2dbcecdac7
commit 54f8a615fc
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
piker/storage/cli.py
View File

@ -152,11 +152,15 @@ def anal(
src_df = await client.as_df(fqme, period) src_df = await client.as_df(fqme, period)
df = mod.with_dts(src_df) df = mod.with_dts(src_df)
gaps: pl.DataFrame = mod.detect_time_gaps(df) gaps: pl.DataFrame = mod.detect_time_gaps(df)
if gaps.is_empty():
breakpoint()
breakpoint() # TODO: something better with tab completion..
# await tractor.breakpoint() # is there something more minimal but nearly as
# functional as ipython?
import code
code.interact(
f'df: {df}\ngaps: {gaps}\n',
local=locals()
)
trio.run(main) trio.run(main)
@ -173,8 +177,10 @@ def clone(
) )
import polars as pl import polars as pl
# TODO: actually look up an existing shm buf (set) from
# an fqme and file name parsing..
# open existing shm buffer for kucoin backend # open existing shm buffer for kucoin backend
key: str = 'piker.brokerd[a9e7a4fe-39ae-44].btcusdt.binance.hist' key: str = 'piker.brokerd[3595d316-3c15-46].xmrusdt.kucoin.hist'
shmpath: Path = Path('/dev/shm') / key shmpath: Path = Path('/dev/shm') / key
assert shmpath.is_file() assert shmpath.is_file()