sin30 commited on
Commit
30bd1c2
·
verified ·
1 Parent(s): 00cfefb

Upload mt_openapi.py

Browse files
Files changed (1) hide show
  1. mt_openapi.py +4 -2
mt_openapi.py CHANGED
@@ -2,6 +2,7 @@ from tenacity import retry, stop_after_delay, wait_fixed, retry_if_result
2
  import requests
3
  import json
4
  import os
 
5
 
6
 
7
  class MTOpenApiClient:
@@ -87,12 +88,13 @@ class MTOpenApiClient:
87
  data={"msg_id": msg_id}
88
  response = requests.post(url, json=data, headers=headers)
89
  response.raise_for_status() # Raise HTTP errors
 
90
  return response.json()
91
 
92
  @retry(
93
  stop=stop_after_delay(1000), # Stop after 100 seconds
94
  wait=wait_fixed(1), # Wait 1 second between retries
95
- retry=retry_if_result(lambda res: res.get("error_code") != 0 and res.get("error_code") != 2) # Retry if error_code != 0
96
  )
97
  def get_res(self, msg_id):
98
  """
@@ -130,7 +132,7 @@ class MTOpenApiClient:
130
  result = self.get_res(msg_id=msg_id)
131
  if result.get("error_code", 0) == 0:
132
  return result
133
-
134
  except requests.RequestException:
135
  if attempt == max_retries - 1:
136
  raise
 
2
  import requests
3
  import json
4
  import os
5
+ import logging
6
 
7
 
8
  class MTOpenApiClient:
 
88
  data={"msg_id": msg_id}
89
  response = requests.post(url, json=data, headers=headers)
90
  response.raise_for_status() # Raise HTTP errors
91
+ logging.info(f"fetch_response: {response.json()}")
92
  return response.json()
93
 
94
  @retry(
95
  stop=stop_after_delay(1000), # Stop after 100 seconds
96
  wait=wait_fixed(1), # Wait 1 second between retries
97
+ retry=retry_if_result(lambda res: res.get("error_code") == 4) # Retry if error_code != 0
98
  )
99
  def get_res(self, msg_id):
100
  """
 
132
  result = self.get_res(msg_id=msg_id)
133
  if result.get("error_code", 0) == 0:
134
  return result
135
+
136
  except requests.RequestException:
137
  if attempt == max_retries - 1:
138
  raise