Skip to content

Commit 145ec94

Browse files
committed
refactor: update trade dates, Python version support, and dependencies
1 parent 73eed0a commit 145ec94

File tree

5 files changed

+528
-39
lines changed

5 files changed

+528
-39
lines changed

QUANTAXIS/QAEngine/QAAsyncThread.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,15 @@
11
import asyncio
22
import threading
3-
from functools import wraps
43

54
from janus import Queue as QA_AsyncQueue
65

76
from QUANTAXIS.QAEngine.QAEvent import QA_Event
8-
from QUANTAXIS.QAUtil import QA_util_log_info, QA_util_random_with_topic, RUNNING_STATUS
7+
from QUANTAXIS.QAUtil import QA_util_random_with_topic, RUNNING_STATUS
98

109

1110
class QA_AsyncThread(threading.Thread):
1211
_loop = asyncio.new_event_loop()
13-
_queue: QA_AsyncQueue = QA_AsyncQueue(loop=_loop)
12+
_queue: QA_AsyncQueue = QA_AsyncQueue()
1413

1514
def __init__(self, name=None, *args, **kwargs):
1615
super().__init__(*args, **kwargs)

0 commit comments

Comments
 (0)