1
0
Fork 0

add pending job list to pool

This commit is contained in:
Sean Sube 2023-03-18 17:26:28 -05:00
parent 8cbdad3a71
commit e08a9aa2ab
Signed by: ssube
GPG Key ID: 3EED7B957D362AF1
1 changed files with 2 additions and 1 deletions

View File

@ -58,9 +58,10 @@ class DevicePoolExecutor:
self.threads = {} self.threads = {}
self.workers = {} self.workers = {}
self.running_jobs = {}
self.cancelled_jobs = [] self.cancelled_jobs = []
self.finished_jobs = [] self.finished_jobs = []
self.pending_jobs = []
self.running_jobs = {}
self.total_jobs = {} self.total_jobs = {}
self.logs = Queue(self.max_pending_per_worker) self.logs = Queue(self.max_pending_per_worker)