update cron job
This commit is contained in:
parent
eb023e4d91
commit
2e5c388783
@ -62,10 +62,10 @@ async def run():
|
|||||||
async with aiohttp.ClientSession() as session:
|
async with aiohttp.ClientSession() as session:
|
||||||
benzinga_news = await get_latest_bezinga_market_news(session)
|
benzinga_news = await get_latest_bezinga_market_news(session)
|
||||||
try:
|
try:
|
||||||
with open(f"json/congress-trading/rss-feed/data.json", 'r') as file:
|
with open(f"json/retail-volume/data.json", 'r') as file:
|
||||||
congress_flow = ujson.load(file)[0:4]
|
retail_tracker = ujson.load(file)[0:5]
|
||||||
except:
|
except:
|
||||||
congress_flow = []
|
retail_tracker = []
|
||||||
try:
|
try:
|
||||||
with open(f"json/options-flow/feed/data.json", 'r') as file:
|
with open(f"json/options-flow/feed/data.json", 'r') as file:
|
||||||
options_flow = ujson.load(file)
|
options_flow = ujson.load(file)
|
||||||
@ -102,7 +102,7 @@ async def run():
|
|||||||
|
|
||||||
quick_info = {**market_mover, 'shorted': shorted_stock}
|
quick_info = {**market_mover, 'shorted': shorted_stock}
|
||||||
|
|
||||||
data = {'quickInfo': quick_info, 'optionsFlow': options_flow, 'congressFlow': congress_flow, 'wiimFeed': wiim_feed, 'marketNews': benzinga_news}
|
data = {'quickInfo': quick_info, 'optionsFlow': options_flow, 'retailTracker': retail_tracker, 'wiimFeed': wiim_feed, 'marketNews': benzinga_news}
|
||||||
|
|
||||||
if len(data) > 0:
|
if len(data) > 0:
|
||||||
await save_json(data)
|
await save_json(data)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user