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

cast ts to int

Browse Source
This commit is contained in:
Arseniy Fomchenko 2017-04-11 18:21:28 +03:00
parent aea93b1d6b
commit a029cb3f14
2 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
yandextank/plugins/Telegraf/collector.py
View File

@ -93,7 +93,7 @@ class MonitoringCollector(object):
return 0
for chunk in collect:
ts, prepared_results = chunk
if self.load_start_time and ts >= self.load_start_time:
if self.load_start_time and int(ts) >= self.load_start_time:
ready_to_send = {
"timestamp": int(ts),
"data": {

7
yandextank/plugins/Telegraf/plugin.py
View File

@ -186,12 +186,6 @@ class Plugin(AbstractPlugin):
if self.default_target:
self.monitoring.default_target = self.default_target
# FIXME json report already save this artifact, fix pls
self.data_file = self.core.mkstemp(".data", "monitoring_overall_")
self.mon_saver = SaveMonToFile(self.data_file)
self.monitoring.add_listener(self.mon_saver)
self.core.add_artifact_file(self.data_file)
try:
console = self.core.get_plugin_of_type(ConsolePlugin)
except Exception as ex:
@ -216,6 +210,7 @@ class Plugin(AbstractPlugin):
raise
else:
self.monitoring = None
time.sleep(10)
def is_test_finished(self):
if self.monitoring: