in benchmarks/horovod-resnet/train_imagenet_resnet_hvd.py [0:0]
def after_create_session(self, session, coord):
enqueue_ops = tf.get_collection("STAGING_AREA_PUTS")
for i in range(len(enqueue_ops)):
session.run(enqueue_ops[: i + 1])