File tree Expand file tree Collapse file tree 1 file changed +0
-7
lines changed Expand file tree Collapse file tree 1 file changed +0
-7
lines changed Original file line number Diff line number Diff line change @@ -117,7 +117,6 @@ def run_jobs(self,
117
117
class MultithreadedJobExecutor (JobExecutor ):
118
118
def __init__ (self ):
119
119
super (MultithreadedJobExecutor , self ).__init__ ()
120
- self .fetch_iter_lock = threading .Lock ()
121
120
self .threads = set ()
122
121
self .exceptions = []
123
122
@@ -132,18 +131,12 @@ def runner():
132
131
133
132
self .threads .remove (thread )
134
133
135
- if self .fetch_iter_lock .locked ():
136
- self .fetch_iter_lock .release ()
137
-
138
134
thread = threading .Thread (target = runner )
139
135
thread .daemon = True
140
136
self .threads .add (thread )
141
137
thread .start ()
142
138
143
139
def wait_for_next_completion (self ):
144
- self .fetch_iter_lock .acquire ()
145
- self .fetch_iter_lock .acquire ()
146
- self .fetch_iter_lock .release ()
147
140
if self .exceptions :
148
141
raise self .exceptions [0 ]
149
142
You can’t perform that action at this time.
0 commit comments