修改定时任务执行时间

main.py

@@ -80,9 +80,10 @@ async def startup():
     app.state.scheduler.add_job(
         cmc_price.update_scheduler_task,
         id='ohlcv_update_task',
-        trigger=interval.IntervalTrigger(hours=1, minutes=10, timezone=pytz.UTC),
+        # trigger=interval.IntervalTrigger(hours=1, minutes=10, timezone=pytz.UTC),
         jobstore='memory',
-        misfire_grace_time=600 * 3
+        misfire_grace_time=600 * 3,
+        trigger='cron', minute=10, second=0,
     )
 
     # app.state.permission_tree, app.state.label_map = make_permission_tree_and_label_map()
@@ -91,9 +92,11 @@ async def startup():
         update_staking_node_status_task,
         args=(BeaconChaService(), app.state.mongodb_manager,),
         id='update_staking_bill_status',
-        trigger=interval.IntervalTrigger(minutes=1, timezone=pytz.UTC),
+        # trigger=interval.IntervalTrigger(minutes=1, timezone=pytz.UTC),
         jobstore='memory',
-        misfire_grace_time=20
+        misfire_grace_time=20,
+        trigger='cron', second=0,
+
     )
 
     # if settings.env == 'LOCAL':

service/price.py

@@ -309,7 +309,7 @@ if __name__ == '__main__':
     mongodb_manager = AioMongodbManager()
     mongodb_manager.setup_pool(settings.py_fund_mongodb_uri, 'pyfund')
     cmc_price = CMCPrice(mongodb_manager)
-    # asyncio.run(cmc_price.start_update_and_init())
+    asyncio.run(cmc_price.start_update_and_init())
     # asyncio.run(cmc_price.get_index_price_map(cmc_price.base_coins))
 
     # asyncio.run(cmc_price.save_history_data('BTC'))