jobs - fix encoding error on CentOS
This commit is contained in:
parent
f0f432487b
commit
7045c0c2b6
11
jobs/Job.py
11
jobs/Job.py
@ -116,10 +116,11 @@ class Job(abc.ABC) :
|
|||||||
if self._redis == None :
|
if self._redis == None :
|
||||||
if os.path.isfile("/tmp/" + self._filename) :
|
if os.path.isfile("/tmp/" + self._filename) :
|
||||||
os.remove("/tmp/" + self._filename)
|
os.remove("/tmp/" + self._filename)
|
||||||
mode = "a"
|
# mode = "a"
|
||||||
if self._type == "file" :
|
# if self._type == "file" :
|
||||||
mode = "ab"
|
# mode = "ab"
|
||||||
file = open("/tmp/" + self._filename, mode)
|
# file = open("/tmp/" + self._filename, mode)
|
||||||
|
file = open("/tmp/" + self._filename, "ab")
|
||||||
|
|
||||||
elif self._redis != None :
|
elif self._redis != None :
|
||||||
pipe = self._redis.pipeline()
|
pipe = self._redis.pipeline()
|
||||||
@ -138,7 +139,7 @@ class Job(abc.ABC) :
|
|||||||
if self._type in ["line", "json"] :
|
if self._type in ["line", "json"] :
|
||||||
chunks = self._edit(chunk)
|
chunks = self._edit(chunk)
|
||||||
for more_chunk in chunks :
|
for more_chunk in chunks :
|
||||||
file.write(more_chunk + "\n")
|
file.write(more_chunk.encode("utf-8") + b"\n")
|
||||||
else :
|
else :
|
||||||
file.write(chunk)
|
file.write(chunk)
|
||||||
else :
|
else :
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user