sonar lint
This commit is contained in:
parent
36bfccae09
commit
bb5d0635d1
|
@ -505,6 +505,7 @@ def logger_main(pool: DevicePoolExecutor, logs: "Queue[str]"):
|
||||||
msg = logs.get(pool.join_timeout / 2)
|
msg = logs.get(pool.join_timeout / 2)
|
||||||
logger.debug("received logs from worker: %s", msg)
|
logger.debug("received logs from worker: %s", msg)
|
||||||
except Empty:
|
except Empty:
|
||||||
|
# logger worker should not generate more logs if it doesn't have any logs
|
||||||
pass
|
pass
|
||||||
except ValueError:
|
except ValueError:
|
||||||
break
|
break
|
||||||
|
@ -524,7 +525,6 @@ def progress_main(pool: DevicePoolExecutor):
|
||||||
progress = context.progress.get_nowait()
|
progress = context.progress.get_nowait()
|
||||||
except Empty:
|
except Empty:
|
||||||
logger.trace("empty queue in leaking worker for device %s", device)
|
logger.trace("empty queue in leaking worker for device %s", device)
|
||||||
pass
|
|
||||||
except ValueError as e:
|
except ValueError as e:
|
||||||
logger.debug("value error in leaking worker for device %s: %s", device, e)
|
logger.debug("value error in leaking worker for device %s: %s", device, e)
|
||||||
break
|
break
|
||||||
|
@ -539,7 +539,6 @@ def progress_main(pool: DevicePoolExecutor):
|
||||||
progress = queue.get_nowait()
|
progress = queue.get_nowait()
|
||||||
except Empty:
|
except Empty:
|
||||||
logger.trace("empty queue in progress worker for device %s", device)
|
logger.trace("empty queue in progress worker for device %s", device)
|
||||||
pass
|
|
||||||
except ValueError as e:
|
except ValueError as e:
|
||||||
logger.debug("value error in progress worker for device %s: %s", device, e)
|
logger.debug("value error in progress worker for device %s: %s", device, e)
|
||||||
break
|
break
|
||||||
|
|
Loading…
Reference in New Issue