Merge pull request #351 from nnugumanov/release

removed send_console

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()

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)

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)