apply lint
This commit is contained in:
parent
4ddd69ba07
commit
0ea0442f02
|
@ -297,13 +297,13 @@ class DevicePoolExecutor:
|
||||||
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)
|
||||||
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
|
||||||
except Exception:
|
except Exception:
|
||||||
logger.exception("error in leaking worker for device %s", device)
|
logger.exception("error in leaking worker for device %s", device)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
self.leaking[:] = [dw for dw in self.leaking if dw[1].is_alive()]
|
self.leaking[:] = [dw for dw in self.leaking if dw[1].is_alive()]
|
||||||
|
|
||||||
def recycle(self):
|
def recycle(self):
|
||||||
|
|
Loading…
Reference in New Issue