fix: kingClient get_token request
This commit is contained in:
parent
2319ecde61
commit
facecacc38
|
@ -35,15 +35,16 @@ class KingClient(HandleLogMixin):
|
|||
# is_ok, _ = self.request(**kapis['heartbeat'], raise_exception=False, timeout=10)
|
||||
# if is_ok == 'success':
|
||||
# return
|
||||
json = {
|
||||
'username': settings.KING_USERNAME,
|
||||
'password': settings.KING_PASSWORD
|
||||
}
|
||||
cache.set('king_token_request', 'requesting')
|
||||
_, res = self.request(
|
||||
**kapis['login'], json=json, timeout=10)
|
||||
cache.set('king_token', res['Authorization'], timeout=None)
|
||||
cache.set('king_token_request', 'done')
|
||||
if cache.get('king_token_request', None) != 'requesting':
|
||||
json = {
|
||||
'username': settings.KING_USERNAME,
|
||||
'password': settings.KING_PASSWORD
|
||||
}
|
||||
cache.set('king_token_request', 'requesting')
|
||||
_, res = self.request(
|
||||
**kapis['login'], json=json, timeout=10)
|
||||
cache.set('king_token', res['Authorization'], timeout=None)
|
||||
cache.set('king_token_request', 'done')
|
||||
|
||||
def request(self, url: str, method: str = 'post', params=dict(), json=dict(), timeout=20, raise_exception=True):
|
||||
if not self.king_enabled:
|
||||
|
|
Loading…
Reference in New Issue