diff --git a/python/otbtf.py b/python/otbtf.py index 66198006b0e0fce1e61d2df243b7f4147d4f2d4e..a925d3ea07b3a0d54bca439fd011be5ccb1f62a0 100644 --- a/python/otbtf.py +++ b/python/otbtf.py @@ -394,12 +394,12 @@ class Dataset: # buffers self.miner_buffer = Buffer(buffer_length) + self.mining_lock = multiprocessing.Lock() self.consumer_buffer = Buffer(buffer_length) self.consumer_buffer_pos = 0 self.tot_wait = 0 self.miner_thread = self._summon_miner_thread() self.read_lock = multiprocessing.Lock() - self.mining_lock = multiprocessing.Lock() self._dump() # Prepare tf dataset for one epoch