OLD | NEW |
1 # Copyright 2013 The Chromium Authors. All rights reserved. | 1 # Copyright 2013 The Chromium Authors. All rights reserved. |
2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
4 | 4 |
5 import time | 5 import time |
6 import traceback | 6 import traceback |
7 | 7 |
8 from app_yaml_helper import AppYamlHelper | 8 from app_yaml_helper import AppYamlHelper |
9 from appengine_wrappers import IsDeadlineExceededError, logservice, taskqueue | 9 from appengine_wrappers import IsDeadlineExceededError, logservice, taskqueue |
10 from branch_utility import BranchUtility | 10 from branch_utility import BranchUtility |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
107 [('content_providers', server_instance.content_providers), | 107 [('content_providers', server_instance.content_providers), |
108 ('platform_bundle', server_instance.platform_bundle)]) | 108 ('platform_bundle', server_instance.platform_bundle)]) |
109 title = 'initializing %s parallel targets' % len(targets) | 109 title = 'initializing %s parallel targets' % len(targets) |
110 _log.info(title) | 110 _log.info(title) |
111 timer = Timer() | 111 timer = Timer() |
112 for name, target in targets: | 112 for name, target in targets: |
113 refresh_paths = target.GetRefreshPaths() | 113 refresh_paths = target.GetRefreshPaths() |
114 for path in refresh_paths: | 114 for path in refresh_paths: |
115 queue.add(taskqueue.Task(url='/_refresh/%s/%s' % (name, path), | 115 queue.add(taskqueue.Task(url='/_refresh/%s/%s' % (name, path), |
116 params={'commit': master_commit})) | 116 params={'commit': master_commit})) |
| 117 queue.add(taskqueue.Task(url='/_refresh/instance_master', |
| 118 params={'commit': master_commit})) |
117 _log.info('%s took %s' % (title, timer.Stop().FormatElapsed())) | 119 _log.info('%s took %s' % (title, timer.Stop().FormatElapsed())) |
118 except: | 120 except: |
119 # This should never actually happen (each cron step does its own | 121 # This should never actually happen (each cron step does its own |
120 # conservative error checking), so re-raise no matter what it is. | 122 # conservative error checking), so re-raise no matter what it is. |
121 _log.error('uncaught error: %s' % traceback.format_exc()) | 123 _log.error('uncaught error: %s' % traceback.format_exc()) |
122 success = False | 124 success = False |
123 raise | 125 raise |
124 finally: | 126 finally: |
125 _log.info('finished (%s)', 'success' if success else 'FAILED') | 127 _log.info('finished (%s)', 'success' if success else 'FAILED') |
126 return (Response.Ok('Success') if success else | 128 return (Response.Ok('Success') if success else |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
179 github_file_system_provider = self._delegate.CreateGithubFileSystemProvider( | 181 github_file_system_provider = self._delegate.CreateGithubFileSystemProvider( |
180 object_store_creator) | 182 object_store_creator) |
181 gcs_file_system_provider = self._delegate.CreateGCSFileSystemProvider( | 183 gcs_file_system_provider = self._delegate.CreateGCSFileSystemProvider( |
182 object_store_creator) | 184 object_store_creator) |
183 return ServerInstance(object_store_creator, | 185 return ServerInstance(object_store_creator, |
184 CompiledFileSystem.Factory(object_store_creator), | 186 CompiledFileSystem.Factory(object_store_creator), |
185 branch_utility, | 187 branch_utility, |
186 host_file_system_provider, | 188 host_file_system_provider, |
187 github_file_system_provider, | 189 github_file_system_provider, |
188 gcs_file_system_provider) | 190 gcs_file_system_provider) |
OLD | NEW |