From be1fd7d624efaafbb7d11bf2f5efeb3c6ce53f14 Mon Sep 17 00:00:00 2001 From: Natalia Serrano Date: Thu, 28 Nov 2024 10:18:34 +0100 Subject: [PATCH] refs #1112 fix bug while accessing object member --- src/opengnsys/workers/oglive_worker.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/opengnsys/workers/oglive_worker.py b/src/opengnsys/workers/oglive_worker.py index d7da9c1..5eaae01 100644 --- a/src/opengnsys/workers/oglive_worker.py +++ b/src/opengnsys/workers/oglive_worker.py @@ -190,8 +190,8 @@ class ogLiveWorker(ServerWorker): logger.debug (f'considering thread ({k})') if self.q: - if not q.empty(): - elem['child_pid'] = q.get() + if not self.q.empty(): + elem['child_pid'] = self.q.get() logger.debug (f'queue not empty, got pid ({elem["child_pid"]})') else: logger.debug (f'queue empty') @@ -413,7 +413,7 @@ class ogLiveWorker(ServerWorker): import queue self.q = queue.Queue() ## a single queue works for us because we never have more than one long_running_job at the same time self.thread_list[job_id] = { - 'thread': ThreadWithResult (target=f, args=args), + 'thread': ThreadWithResult (target=f, args=args), ## tengo que pasar self.q aqui dentro de args? 'starttime': time.time(), 'child_pid': None, 'running': True,