pikers
/
piker
3
0
Fork 0
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Drop use of deprecated `trio.Event.clear()`

relicense_as_agplv3
Tyler Goodlet 2020-06-02 10:33:57 -04:00
parent eccd9e2ffb
commit 2c93bb0302
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
piker/brokers/questrade.py
View File

@ -84,7 +84,7 @@ def refresh_token_on_err(tries=3):
for i in range(1, tries): for i in range(1, tries):
try: try:
try: try:
client._request_not_in_progress.clear() client._request_not_in_progress = trio.Event()
return await wrapped(*args, **kwargs) return await wrapped(*args, **kwargs)
finally: finally:
client._request_not_in_progress.set() client._request_not_in_progress.set()
@ -303,7 +303,7 @@ class Client:
# token whereby their service can't handle concurrent requests # token whereby their service can't handle concurrent requests
# to differnet end points (particularly the auth ep) which # to differnet end points (particularly the auth ep) which
# causes hangs and premature token invalidation issues. # causes hangs and premature token invalidation issues.
self._has_access.clear() self._has_access = trio.Event()
try: try:
# don't allow simultaneous token refresh requests # don't allow simultaneous token refresh requests
async with self._mutex: async with self._mutex: