valitydev/yandex-tank
14
0
Fork 0
mirror of https://github.com/valitydev/yandex-tank.git synced 2024-11-06 02:15:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

removed console snapshot sending

Browse Source
This commit is contained in:
Nurlan Nugumanov 2017-04-05 21:11:40 +03:00
parent f93432ab4d
commit eace9847f4
2 changed files with 0 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
yandextank/plugins/DataUploader/client.py
View File

@ -547,13 +547,6 @@ class APIClient(object):
except StopIteration: except StopIteration:
raise e 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): def is_target_locked(self, target, trace=False):
addr = "api/server/lock.json?action=check&address=%s" % target addr = "api/server/lock.json?action=check&address=%s" % target
res = self.__get(addr, trace=trace) res = self.__get(addr, trace=trace)

10
yandextank/plugins/DataUploader/plugin.py
View File

@ -467,12 +467,6 @@ class Plugin(AbstractPlugin, AggregateResultListener,
with open(os.path.join(self.core.artifacts_dir, 'saved_conf.ini'), 'w') as f: with open(os.path.join(self.core.artifacts_dir, 'saved_conf.ini'), 'w') as f:
config.write(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): def parse_lock_targets(self):
# prepare target lock list # prepare target lock list
locks_list_cfg = self.get_option('lock_targets', 'auto').strip() locks_list_cfg = self.get_option('lock_targets', 'auto').strip()
@ -808,10 +802,6 @@ class LPJob(object):
self.api_client.push_monitoring_data( self.api_client.push_monitoring_data(
self.number, self.token, data, trace=self.log_monitoring_requests) 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): def lock_target(self, lock_target, lock_target_duration, ignore, strict):
lock_wait_timeout = 10 lock_wait_timeout = 10
maintenance_timeouts = iter([0]) if ignore else iter(lambda: lock_wait_timeout, 0) maintenance_timeouts = iter([0]) if ignore else iter(lambda: lock_wait_timeout, 0)