Merge pull request #137 from codingo/sober-fix

Sober fix
This commit is contained in:
Michael Skelton
2021-02-23 17:24:36 +10:00
committed by GitHub
2 changed files with 12 additions and 11 deletions

View File

@@ -1 +1 @@
__version__ = '1.9.2'
__version__ = '1.9.3'

View File

@@ -47,23 +47,24 @@ class Task(object):
return self.self_lock
def _run_task(self, t=False):
if t:
s = subprocess.Popen(self.task, shell=True,
stdout=subprocess.PIPE,
encoding="utf-8")
out, _ = s.communicate()
if out != "":
if t:
t.write(out)
else:
subprocess.Popen(self.task, shell=True)
print(out)
class Worker(object):
def __init__(self, task_queue, timeout, output, tqdm):
def __init__(self, task_queue, timeout, output, tq):
self.queue = task_queue
self.timeout = timeout
self.output = output
self.tqdm = tqdm
self.tqdm = tq
def __call__(self):
queue = self.queue