822a66e8b1d3a830fa3d2de72c2b2af00d541e03,magenta/pipelines/pipeline.py,,run_pipeline_serial,#Any#Any#Any#,160

Before Change

        total_outputs += 1
    if total_inputs % 500 == 0:
      tf.logging.info("%d inputs. %d outputs. stats = %s", total_inputs,
                      total_outputs, pipeline.get_stats())


def load_pipeline(pipeline, input_iterator):

After Change

      for output in outputs:
        writers[name].write(output.SerializeToString())
        total_outputs += 1
    stats = statistics.merge_statistics(stats + pipeline.get_stats())
    if total_inputs % 500 == 0:
      tf.logging.info("Processed %d inputs so far. Produced %d outputs.",
                      total_inputs, total_outputs)
      statistics.log_statistics_list(stats, tf.logging.info)

Instances