buildbucket: support unique change urls

scripts/master/buildbucket/unittests/integration_test.py

 #!/usr/bin/env python
 # 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.
 
 """Buildbucket integration unit tests"""
 
 import contextlib
 import datetime
 import httplib
@@ skipping 104 matching lines @@
     self.changes.get_source_stamp.return_value = self.ssid
 
   @contextlib.contextmanager
   def create_integrator(self, buildbot=None, max_lease_count=None,
                         build_params_hook=None):
     self.buildbucket = fake_buildbucket()
     self.buildbot = buildbot or fake_buildbot()
     self.integrator = integration.BuildBucketIntegrator(
         self.buckets, max_lease_count=max_lease_count,
         build_params_hook=build_params_hook,
-        heartbeat_interval=datetime.timedelta(microseconds=1))
+        heartbeat_interval=datetime.timedelta(microseconds=1),
+        change_store_factory=lambda bb: self.changes)
     def log(msg, level=logging.INFO):
       logging.log(level, msg)
     self.integrator.log = log
-    self.integrator.start(
-        self.buildbot, self.buildbucket,
-        change_store_factory=lambda bb: self.changes)
+    self.integrator.start(self.buildbot, self.buildbucket)
     try:
       yield
     finally:
       self.integrator.stop()
 
   def test_no_builds(self):
     with self.create_integrator():
       self.buildbucket.api.peek.return_value = {'builds': []}
       run_deferred(self.integrator.poll_builds())
       self.assertFalse(self.buildbot.add_build_request.called)
@@ skipping 477 matching lines @@
       self.assertFalse(build.id in self.integrator._leases)
       self.assertFalse(self.buildbucket.api.fail.called)
 
 
 if __name__ == '__main__':
   logging.basicConfig(
       level=(logging.DEBUG if '-v' in sys.argv else logging.FATAL))
   if '-v' in sys.argv:
     unittest.TestCase.maxDiff = None
   unittest.main()