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

Flip `tractor.breakpoint()`s to new `.pause()`

account_tests
Tyler Goodlet 2023-07-26 12:48:19 -04:00
parent bd0af7a4c0
commit 64329d44e7
8 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
piker/brokers/binance/broker.py
View File

@ -323,7 +323,7 @@ async def open_trade_dialog(
if balance > 0: if balance > 0:
balances[spot_asset] = (balance, last_update_t) balances[spot_asset] = (balance, last_update_t)
# await tractor.breakpoint() # await tractor.pause()
# @position response: # @position response:
# {'positions': [{'entryPrice': '0.0', # {'positions': [{'entryPrice': '0.0',

2
piker/brokers/binance/feed.py
View File

@ -265,7 +265,7 @@ async def open_history_client(
): ):
inow = round(time.time()) inow = round(time.time())
if (inow - times[-1]) > 60: if (inow - times[-1]) > 60:
await tractor.breakpoint() await tractor.pause()
start_dt = from_timestamp(times[0]) start_dt = from_timestamp(times[0])
end_dt = from_timestamp(times[-1]) end_dt = from_timestamp(times[-1])

2
piker/data/_sampling.py
View File

@ -717,7 +717,7 @@ async def sample_and_broadcast(
if cs.cancelled_caught: if cs.cancelled_caught:
lags += 1 lags += 1
if lags > 10: if lags > 10:
await tractor.breakpoint() await tractor.pause()
except ( except (
trio.BrokenResourceError, trio.BrokenResourceError,

7
piker/data/history.py
View File

@ -141,8 +141,7 @@ async def shm_push_in_between(
array = shm.array array = shm.array
zeros = array[array['low'] == 0] zeros = array[array['low'] == 0]
if 0 < zeros.size < 1000: if 0 < zeros.size < 1000:
tractor.breakpoint() await tractor.pause()
async def start_backfill( async def start_backfill(
@ -255,7 +254,7 @@ async def start_backfill(
# f"{mkt.fqme}: skipping duplicate frame @ {next_start_dt}" # f"{mkt.fqme}: skipping duplicate frame @ {next_start_dt}"
# ) # )
# starts[start_dt] += 1 # starts[start_dt] += 1
# await tractor.breakpoint() # await tractor.pause()
# continue # continue
# elif starts[next_start_dt] > 6: # elif starts[next_start_dt] > 6:
@ -484,7 +483,7 @@ async def back_load_from_tsdb(
if storemod.name == 'nativedb': if storemod.name == 'nativedb':
return return
await tractor.breakpoint() await tractor.pause()
assert shm._first.value == 0 assert shm._first.value == 0
array = shm.array array = shm.array

4
piker/storage/cli.py
View File

@ -177,7 +177,7 @@ def anal(
# TODO: something better with tab completion.. # TODO: something better with tab completion..
# is there something more minimal but nearly as # is there something more minimal but nearly as
# functional as ipython? # functional as ipython?
await tractor.breakpoint() await tractor.pause()
trio.run(main) trio.run(main)
@ -288,7 +288,7 @@ def ldshm(
# TODO: maybe only optionally enter this depending # TODO: maybe only optionally enter this depending
# on some CLI flags and/or gap detection? # on some CLI flags and/or gap detection?
await tractor.breakpoint() await tractor.pause()
# write to parquet file? # write to parquet file?
if write_parquet: if write_parquet:

4
piker/storage/marketstore/__init__.py
View File

@ -204,7 +204,7 @@ class MktsStorageClient:
# break # break
# except purerpc.grpclib.exceptions.UnknownError as err: # except purerpc.grpclib.exceptions.UnknownError as err:
# if 'snappy' in err.args: # if 'snappy' in err.args:
# await tractor.breakpoint() # await tractor.pause()
# # indicate there is no history for this timeframe # # indicate there is no history for this timeframe
# log.exception( # log.exception(
@ -232,7 +232,7 @@ class MktsStorageClient:
'YOUR DATABASE LIKELY CONTAINS BAD DATA FROM AN OLD BUG ' 'YOUR DATABASE LIKELY CONTAINS BAD DATA FROM AN OLD BUG '
f'WIPING HISTORY FOR {ts}s' f'WIPING HISTORY FOR {ts}s'
) )
await tractor.breakpoint() await tractor.pause()
# await self.delete_ts(fqme, timeframe) # await self.delete_ts(fqme, timeframe)
# try reading again.. # try reading again..

2
piker/ui/_display.py
View File

@ -462,7 +462,7 @@ async def graphics_update_loop(
await trio.sleep(0) await trio.sleep(0)
if ds.hist_vars['i_last'] < ds.hist_vars['i_last_append']: if ds.hist_vars['i_last'] < ds.hist_vars['i_last_append']:
await tractor.breakpoint() await tractor.pause()
# main real-time quotes update loop # main real-time quotes update loop
stream: tractor.MsgStream stream: tractor.MsgStream

2
piker/ui/_interaction.py
View File

@ -161,7 +161,7 @@ async def handle_viewmode_kb_inputs(
vlm_chart = chart.linked.subplots['volume'] # noqa vlm_chart = chart.linked.subplots['volume'] # noqa
vlm_viz = vlm_chart.main_viz # noqa vlm_viz = vlm_chart.main_viz # noqa
dvlm_pi = vlm_chart._vizs['dolla_vlm'].plot # noqa dvlm_pi = vlm_chart._vizs['dolla_vlm'].plot # noqa
await tractor.breakpoint() await tractor.pause()
view.interact_graphics_cycle() view.interact_graphics_cycle()
# SEARCH MODE # # SEARCH MODE #