diff --git a/piker/data/history.py b/piker/data/history.py index 99fd425d..46c5f5a6 100644 --- a/piker/data/history.py +++ b/piker/data/history.py @@ -366,7 +366,13 @@ async def start_backfill( f'{next_start_dt} -> {last_start_dt}' ) - if mkt.dst.atype not in {'crypto', 'crypto_currency'}: + # always drop the src asset token for + # non-currency-pair like market types (for now) + if mkt.dst.atype not in { + 'crypto', + 'crypto_currency', + 'fiat', # a "forex pair" + }: # for now, our table key schema is not including # the dst[/src] source asset token. col_sym_key: str = mkt.get_fqme(