refactor: update trade dates, Python version support, and dependencies

yutiansut · Jan 28, 2025 · 145ec94 · 145ec94
1 parent 73eed0a
commit 145ec94
Show file tree

Hide file tree

Showing 5 changed files with 528 additions and 39 deletions.
diff --git a/QUANTAXIS/QAEngine/QAAsyncThread.py b/QUANTAXIS/QAEngine/QAAsyncThread.py
@@ -1,16 +1,15 @@
 import asyncio
 import threading
-from functools import wraps
 
 from janus import Queue as QA_AsyncQueue
 
 from QUANTAXIS.QAEngine.QAEvent import QA_Event
-from QUANTAXIS.QAUtil import QA_util_log_info, QA_util_random_with_topic, RUNNING_STATUS
+from QUANTAXIS.QAUtil import QA_util_random_with_topic, RUNNING_STATUS
 
 
 class QA_AsyncThread(threading.Thread):
     _loop = asyncio.new_event_loop()
-    _queue: QA_AsyncQueue = QA_AsyncQueue(loop=_loop)
+    _queue: QA_AsyncQueue = QA_AsyncQueue()
 
     def __init__(self, name=None, *args, **kwargs):
         super().__init__(*args, **kwargs)