Compare commits
No commits in common. "35cb538a69ed0873fc39fdd3cb43618db2675000" and "8b0fac3b6cb706946f7389587022c48d90bc7342" have entirely different histories.
35cb538a69
...
8b0fac3b6c
|
@ -374,14 +374,9 @@ class Client:
|
||||||
pair: Pair = pair_type(**item)
|
pair: Pair = pair_type(**item)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
e.add_note(
|
e.add_note(
|
||||||
f'\n'
|
"\nDon't panic, prolly stupid binance changed their symbology schema again..\n"
|
||||||
f'New or removed field we need to codify!\n'
|
'Check out their API docs here:\n\n'
|
||||||
f'pair-type: {pair_type!r}\n'
|
'https://binance-docs.github.io/apidocs/spot/en/#exchange-information'
|
||||||
f'\n'
|
|
||||||
f"Don't panic, prolly stupid binance changed their symbology schema again..\n"
|
|
||||||
f'Check out their API docs here:\n'
|
|
||||||
f'\n'
|
|
||||||
f'https://binance-docs.github.io/apidocs/spot/en/#exchange-information\n'
|
|
||||||
)
|
)
|
||||||
raise
|
raise
|
||||||
pair_table[pair.symbol.upper()] = pair
|
pair_table[pair.symbol.upper()] = pair
|
||||||
|
|
|
@ -144,11 +144,6 @@ class SpotPair(Pair, frozen=True):
|
||||||
permissions: list[str]
|
permissions: list[str]
|
||||||
permissionSets: list[list[str]]
|
permissionSets: list[list[str]]
|
||||||
|
|
||||||
# can the paint botz creat liq gaps even easier on this asset?
|
|
||||||
# Bp
|
|
||||||
# https://developers.binance.com/docs/binance-spot-api-docs/faqs/order_amend_keep_priority
|
|
||||||
amendAllowed: bool
|
|
||||||
|
|
||||||
# NOTE: see `.data._symcache.SymbologyCache.load()` for why
|
# NOTE: see `.data._symcache.SymbologyCache.load()` for why
|
||||||
ns_path: str = 'piker.brokers.binance:SpotPair'
|
ns_path: str = 'piker.brokers.binance:SpotPair'
|
||||||
|
|
||||||
|
|
|
@ -161,7 +161,7 @@ async def clear_dark_triggers(
|
||||||
|
|
||||||
router: Router,
|
router: Router,
|
||||||
brokerd_orders_stream: tractor.MsgStream,
|
brokerd_orders_stream: tractor.MsgStream,
|
||||||
quote_stream: tractor.MsgStream,
|
quote_stream: tractor.ReceiveMsgStream, # noqa
|
||||||
broker: str,
|
broker: str,
|
||||||
fqme: str,
|
fqme: str,
|
||||||
|
|
||||||
|
@ -177,7 +177,6 @@ async def clear_dark_triggers(
|
||||||
'''
|
'''
|
||||||
# XXX: optimize this for speed!
|
# XXX: optimize this for speed!
|
||||||
# TODO:
|
# TODO:
|
||||||
# - port to the new ringbuf stuff in `tractor.ipc`!
|
|
||||||
# - numba all this!
|
# - numba all this!
|
||||||
# - this stream may eventually contain multiple symbols
|
# - this stream may eventually contain multiple symbols
|
||||||
quote_stream._raise_on_lag = False
|
quote_stream._raise_on_lag = False
|
||||||
|
|
Loading…
Reference in New Issue