Commit 3ba79139 authored by Jérome Perrin's avatar Jérome Perrin

promise/plugin/util: fix PY2 support

parent d38b5063
...@@ -3,9 +3,11 @@ import json ...@@ -3,9 +3,11 @@ import json
import logging import logging
import os import os
import textwrap import textwrap
import time
from dateutil import parser as dateparser from dateutil import parser as dateparser
from datetime import datetime from datetime import datetime
import six
from slapos.grid.promise.generic import GenericPromise from slapos.grid.promise.generic import GenericPromise
...@@ -16,9 +18,15 @@ def iter_reverse_lines(f): ...@@ -16,9 +18,15 @@ def iter_reverse_lines(f):
f.seek(0, os.SEEK_END) f.seek(0, os.SEEK_END)
while True: while True:
try: try:
while f.seek(-2, os.SEEK_CUR) and f.read(1) != b'\n': if six.PY3:
pass while f.seek(-2, os.SEEK_CUR) and f.read(1) != b'\n':
except OSError: pass
else:
while True:
f.seek(-2, os.SEEK_CUR)
if f.tell() == 0 or f.read(1) == '\n':
break
except (OSError, IOError):
return return
pos = f.tell() pos = f.tell()
yield f.readline() yield f.readline()
...@@ -62,7 +70,10 @@ def get_json_log_latest_timestamp(json_log_file): ...@@ -62,7 +70,10 @@ def get_json_log_latest_timestamp(json_log_file):
for f in iter_logrotate_file_handle(json_log_file, 'rb'): for f in iter_logrotate_file_handle(json_log_file, 'rb'):
for line in iter_reverse_lines(f): for line in iter_reverse_lines(f):
l = json.loads(line.decode().replace("'", '"')) l = json.loads(line.decode().replace("'", '"'))
return dateparser.parse(l['time']).timestamp() date = dateparser.parse(l['time'])
if six.PY2:
return time.mktime(date.timetuple())
return date.timestamp()
return 0 return 0
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment