|
|
@@ -11,6 +11,7 @@ import os
|
|
|
import lighter
|
|
|
import time
|
|
|
import json
|
|
|
+import asyncio
|
|
|
from database import TradingDatabase
|
|
|
|
|
|
|
|
|
@@ -803,7 +804,6 @@ class TradingStrategy:
|
|
|
|
|
|
async def _periodic_account_update(self):
|
|
|
"""定期更新账户信息的后台任务"""
|
|
|
- import asyncio
|
|
|
|
|
|
while True:
|
|
|
try:
|
|
|
@@ -828,8 +828,6 @@ class TradingStrategy:
|
|
|
await asyncio.sleep(1)
|
|
|
|
|
|
async def _periodic_db_flush(self):
|
|
|
- """定期刷新数据库缓冲区的后台任务"""
|
|
|
- import asyncio
|
|
|
|
|
|
while True:
|
|
|
try:
|
|
|
@@ -970,6 +968,4 @@ async def main():
|
|
|
# print(new_oid)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
- import asyncio
|
|
|
-
|
|
|
asyncio.run(main())
|
