Indefinitely wait on feed hack for windows?
parent
d8db9233c9
commit
bcb4fe8c50
|
@ -37,7 +37,6 @@ import asyncio
|
||||||
from pprint import pformat
|
from pprint import pformat
|
||||||
import inspect
|
import inspect
|
||||||
import logging
|
import logging
|
||||||
import platform
|
|
||||||
from random import randint
|
from random import randint
|
||||||
import time
|
import time
|
||||||
|
|
||||||
|
@ -1583,7 +1582,7 @@ async def backfill_bars(
|
||||||
# on that until we have the `marketstore` daemon in place in which
|
# on that until we have the `marketstore` daemon in place in which
|
||||||
# case the shm size will be driven by user config and available sys
|
# case the shm size will be driven by user config and available sys
|
||||||
# memory.
|
# memory.
|
||||||
count: int = 100,
|
count: int = 16,
|
||||||
|
|
||||||
task_status: TaskStatus[trio.CancelScope] = trio.TASK_STATUS_IGNORED,
|
task_status: TaskStatus[trio.CancelScope] = trio.TASK_STATUS_IGNORED,
|
||||||
|
|
||||||
|
@ -1603,11 +1602,6 @@ async def backfill_bars(
|
||||||
# async with open_history_client(fqsn) as proxy:
|
# async with open_history_client(fqsn) as proxy:
|
||||||
async with open_client_proxy() as proxy:
|
async with open_client_proxy() as proxy:
|
||||||
|
|
||||||
if platform.system() == 'Windows':
|
|
||||||
log.warning(
|
|
||||||
'Decreasing history query count to 4 since, windows...')
|
|
||||||
count = 4
|
|
||||||
|
|
||||||
out, fails = await get_bars(proxy, fqsn)
|
out, fails = await get_bars(proxy, fqsn)
|
||||||
|
|
||||||
if out is None:
|
if out is None:
|
||||||
|
|
Loading…
Reference in New Issue