From afafd899822d3460c237a7871eac7eb743c4e375 Mon Sep 17 00:00:00 2001 From: Colombo Date: Wed, 22 Jan 2020 17:23:08 +0400 Subject: [PATCH] 1 --- core/joblib/SubprocessorBase.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/joblib/SubprocessorBase.py b/core/joblib/SubprocessorBase.py index 977681a..7ddd433 100644 --- a/core/joblib/SubprocessorBase.py +++ b/core/joblib/SubprocessorBase.py @@ -247,7 +247,7 @@ class Subprocessor(object): for cli in self.clis[:]: if cli.state == 1: - if cli.sent_time != and self.no_response_time_sec != 0 and (time.time() - cli.sent_time) > self.no_response_time_sec: + if cli.sent_time != 0 and self.no_response_time_sec != 0 and (time.time() - cli.sent_time) > self.no_response_time_sec: #subprocess busy too long print ( '%s doesnt response, terminating it.' % (cli.name) ) self.on_data_return (cli.host_dict, cli.sent_data )