update

locust_test/es_locust_answer.py

@@ -462,8 +462,10 @@ class QuickstartUser(FastHttpUser):
         # }
         with self.client.post('/gm-dbmw-answer-read/_search', json=data,verify=False,
                                     auth=tuple(auth.split(':', 1)),timeout=1) as response:
-            if response.status_code != 200:
-                raise RescheduleTask()
+            # if response.status_code != 200:
+            #     raise RescheduleTask()
+            if "Failed" in response.text:
+                response.failure("Got wrong response")
         # response = requests.post('http://172.16.52.25/gm-dbmw-service-read/_search', json=query, verify=False,auth=("elastic","elastic:gengmei!@#"))
 
         # print(response.text)