[Findit] Fetch DEPS from buildspec/ instead of trunk for chrome official builds.

appengine/findit/crash/test/fracas_crash_pipeline_test.py

 # Copyright 2016 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.
 
 import json
 import os
 
 from common import constants
 from common.pipeline_wrapper import pipeline_handlers
 from crash import fracas_crash_pipeline
 from crash.test.crash_testcase import CrashTestCase
 from model import analysis_status
 from model import result_status
 from model.crash.fracas_crash_analysis import FracasCrashAnalysis
-from waterfall.test import wf_testcase
 
 
 class FracasCrashPipelineTest(CrashTestCase):
   app_module = pipeline_handlers._APP
 
   def testNoAnalysisIfLastOneIsNotFailed(self):
     chrome_version = '1'
     signature = 'signature'
     platform = 'win'
     crash_identifiers = {
@@ skipping 117 matching lines @@
     self.assertTrue(
         fracas_crash_pipeline.ScheduleNewAnalysisForCrash(
             crash_identifiers, chrome_version, signature, 'fracas',
             platform, stack_trace, channel, historic_metadata))
 
     self.execute_queued_tasks()
 
     self.assertEqual(1, len(pubsub_publish_requests))
     expected_messages_data = [json.dumps({
             'crash_identifiers': crash_identifiers,
+            'client_id': 'fracas',
             'result': analysis_result,
         }, sort_keys=True)]
     self.assertEqual(expected_messages_data, pubsub_publish_requests[0][0])
 
     self.assertEqual(1, len(analyzed_crashes))
     self.assertEqual(
-        (channel, platform, signature, stack_trace,
-         chrome_version, historic_metadata),
+        (signature, platform, stack_trace, chrome_version, historic_metadata),
         analyzed_crashes[0])
 
     analysis = FracasCrashAnalysis.Get(crash_identifiers)
     self.assertEqual(analysis_result, analysis.result)
     self.assertTrue(analysis.has_regression_range)
     self.assertTrue(analysis.found_suspects)
     self.assertEqual('core', analysis.solution)
 
   def testAnalysisAborted(self):
     chrome_version = '1'
     signature = 'signature'
     platform = 'win'
     crash_identifiers = {
       'chrome_version': chrome_version,
       'signature': signature,
       'channel': 'canary',
       'platform': platform,
       'process_type': 'browser',
     }
     analysis = FracasCrashAnalysis.Create(crash_identifiers)
     analysis.status = analysis_status.RUNNING
     analysis.put()
 
     pipeline = fracas_crash_pipeline.FracasAnalysisPipeline(crash_identifiers)
     pipeline._SetErrorIfAborted(True)
     analysis = FracasCrashAnalysis.Get(crash_identifiers)
     self.assertEqual(analysis_status.ERROR, analysis.status)