diff --git a/yandextank/plugins/Console/plugin.py b/yandextank/plugins/Console/plugin.py index 7cb9682..f305c24 100644 --- a/yandextank/plugins/Console/plugin.py +++ b/yandextank/plugins/Console/plugin.py @@ -21,7 +21,6 @@ class Plugin(AbstractPlugin, AggregateResultListener): self.screen = None self.render_exception = None self.console_markup = None - self.remote_translator = None self.info_panel_width = '33' self.short_only = 0 # these three provide non-blocking console output @@ -71,9 +70,6 @@ class Plugin(AbstractPlugin, AggregateResultListener): sys.stdout.write(self.__console_view) sys.stdout.write(self.console_markup.TOTAL_RESET) - if self.remote_translator: - self.remote_translator.send_console(self.__console_view) - def is_test_finished(self): if not self.__writer_thread: self.__writer_event = threading.Event() diff --git a/yandextank/plugins/DataUploader/client.py b/yandextank/plugins/DataUploader/client.py index 17ff9cb..3f7c7ff 100644 --- a/yandextank/plugins/DataUploader/client.py +++ b/yandextank/plugins/DataUploader/client.py @@ -547,13 +547,6 @@ class APIClient(object): except StopIteration: raise e - def send_console(self, jobno, console, trace=False): - if trace: - logger.debug("Sending console view [%s]: %s", len(console), - console[:64]) - addr = "api/job/%s/console.txt" % jobno - self.__post_raw(addr, console, trace=trace) - def is_target_locked(self, target, trace=False): addr = "api/server/lock.json?action=check&address=%s" % target res = self.__get(addr, trace=trace) diff --git a/yandextank/plugins/DataUploader/plugin.py b/yandextank/plugins/DataUploader/plugin.py index c9ca914..0516557 100644 --- a/yandextank/plugins/DataUploader/plugin.py +++ b/yandextank/plugins/DataUploader/plugin.py @@ -240,7 +240,6 @@ class Plugin(AbstractPlugin, AggregateResultListener, if console: console.add_info_widget(JobInfoWidget(self)) - console.remote_translator = self self.set_option('target_host', self.target) self.set_option('target_port', port) @@ -467,12 +466,6 @@ class Plugin(AbstractPlugin, AggregateResultListener, with open(os.path.join(self.core.artifacts_dir, 'saved_conf.ini'), 'w') as f: config.write(f) - def send_console(self, text): - try: - self.lp_job.send_console(text) - except Exception: # pylint: disable=W0703 - logger.debug("Can't send console snapshot: %s", exc_info=True) - def parse_lock_targets(self): # prepare target lock list locks_list_cfg = self.get_option('lock_targets', 'auto').strip() @@ -808,10 +801,6 @@ class LPJob(object): self.api_client.push_monitoring_data( self.number, self.token, data, trace=self.log_monitoring_requests) - def send_console(self, text): - return self.api_client.send_console( - self.number, text, trace=self.log_other_requests) - def lock_target(self, lock_target, lock_target_duration, ignore, strict): lock_wait_timeout = 10 maintenance_timeouts = iter([0]) if ignore else iter(lambda: lock_wait_timeout, 0)