def doTest(self, data, num_streams, correct_answer):
    output = analysis.ThroughputStats(
        data['start_time'], data['duration'], data['size'], data['stream_num'],
        num_streams)
    print 'output', output

    for name, value in output.iteritems():
      if correct_answer not in name:
        raise KeyError('ThroughputStats produced key %s not in correct '
                       'output %s' % (name, str(correct_answer)))

      self.assertEqual(value, correct_answer[name])
dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/tests/object_storage_multistream_analysis_test.py/TestThroughputStats.doTest/swapped operands of `not in`