diff --git a/reportportal_client/service_async.py b/reportportal_client/service_async.py index 92f442c1..86047362 100644 --- a/reportportal_client/service_async.py +++ b/reportportal_client/service_async.py @@ -208,8 +208,7 @@ def process_item(self, item): getattr(self.rp_client, method)(**kwargs) except Exception: if self.error_handler: - if not self.error_handler(sys.exc_info()): - self.terminate(nowait=True) + self.error_handler(sys.exc_info()) else: self.terminate(nowait=True) raise