[Findit] Capture and store latest buildbucket response with each query

appengine/findit/waterfall/test/monitor_try_job_pipeline_test.py

 # Copyright 2015 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 from datetime import datetime
 import json
 import time
 
 from common.waterfall import buildbucket_client
 from common.waterfall import failure_type
@@ skipping 115 matching lines @@
   def setUp(self):
     super(MonitorTryJobPipelineTest, self).setUp()
     self.mock(time, 'sleep', lambda x: None)
 
   def testMicrosecondsToDatetime(self):
     self.assertEqual(
         datetime(2016, 2, 1, 22, 59, 34),
         monitor_try_job_pipeline._MicrosecondsToDatetime(1454367574000000))
     self.assertIsNone(monitor_try_job_pipeline._MicrosecondsToDatetime(None))
 
+  def testDictsAreEqual(self):
+    self.assertTrue(monitor_try_job_pipeline._DictsAreEqual(None, None))
+    self.assertTrue(monitor_try_job_pipeline._DictsAreEqual({}, {}))
+    self.assertTrue(monitor_try_job_pipeline._DictsAreEqual({'a': 1}, {'a': 1}))
+    self.assertTrue(monitor_try_job_pipeline._DictsAreEqual(
+        {'a': 1},
+        {'a': 1, 'b': 2},
+        exclude_keys=['b']))
+    self.assertTrue(monitor_try_job_pipeline._DictsAreEqual(
+        {'a': 1, 'b': 1},
+        {'a': 1, 'b': 2},
+        exclude_keys=['b']))
+    self.assertTrue(monitor_try_job_pipeline._DictsAreEqual(
+        {'a': 1},
+        {},
+        exclude_keys=['a']))
+    self.assertFalse(monitor_try_job_pipeline._DictsAreEqual(
+        {'a': 1},
+        {'a': 2}))
+    self.assertFalse(monitor_try_job_pipeline._DictsAreEqual(
+        {'a': 1, 'b': 2},
+        {'a': 1}))
+    self.assertFalse(monitor_try_job_pipeline._DictsAreEqual(
+        {'a': 1},
+        {'a': 1, 'b': 2}))
+
   def testUpdateTryJobMetadataForBuildError(self):
     error_data = {
         'reason': 'BUILD_NOT_FOUND',
         'message': 'message'
     }
     error = buildbucket_client.BuildbucketError(error_data)
     try_job_data = WfTryJobData.Create('1')
 
     monitor_try_job_pipeline._UpdateTryJobMetadata(
         try_job_data, None, None, error, False)
@@ skipping 316 matching lines @@
     }
 
     expected_error_dict = {
         'message': 'No result report was found.',
         'reason': MonitorTryJobPipeline.UNKNOWN
     }
 
     self.assertEqual(
         monitor_try_job_pipeline._GetError(build_response, None, False),
         (expected_error_dict, try_job_error.UNKNOWN))