e9fb47f90dacd64ee9bfe7aafca59b5ff75e739f,niftynet/engine/input_buffer.py,InputBatchQueueRunner,_push,#InputBatchQueueRunner#Any#,105

Before Change

                if self._coordinator.should_stop():
                    break
                self._session.run(self._enqueue_op, feed_dict=output_dict)
            import pdb; pdb.set_trace()

                //// push a set of stopping patches
                // for i in range(0, self.capacity):
                //    if self._session._closed:

After Change

                    break
                if self._coordinator.should_stop():
                    break
                for name in list(output_dict):
                    output_dict[name] = np.zeros_like(output_dict[name])
                self._session.run(self._enqueue_op, feed_dict=output_dict)

        except tf.errors.CancelledError:
            pass

Instances