author | Tom Prince <mozilla@hocat.ca> |
Mon, 23 Apr 2018 13:08:28 -0600 | |
changeset 415656 | 51c27d9d25eaca9db40ef561bd3f9cdab63bf9b0 |
parent 415655 | f864f16fdd38b52e30ce5d064b4f8c1c0fb8ae9e |
child 415657 | 1527cfbcd067b594afc71fc2a7673f5bffed1a94 |
push id | 33901 |
push user | apavel@mozilla.com |
push date | Thu, 26 Apr 2018 06:05:37 +0000 |
treeherder | mozilla-central@b62ad926cf2a [default view] [failures only] |
perfherder | [talos] [build metrics] [platform microbench] (compared to previous push) |
reviewers | dustin |
bugs | 1418058 |
milestone | 61.0a1 |
first release with | nightly linux32
nightly linux64
nightly mac
nightly win32
nightly win64
|
last release without | nightly linux32
nightly linux64
nightly mac
nightly win32
nightly win64
|
taskcluster/taskgraph/actions/cancel_all.py | file | annotate | diff | comparison | revisions | |
taskcluster/taskgraph/actions/purge_caches.py | file | annotate | diff | comparison | revisions |
--- a/taskcluster/taskgraph/actions/cancel_all.py +++ b/taskcluster/taskgraph/actions/cancel_all.py @@ -42,17 +42,17 @@ def list_group(task_group_id, session): symbol='cAll', description=( 'Cancel all running and pending tasks created by the decision task ' 'this action task is associated with.' ), order=100, context=[] ) -def cancel_all_action(parameters, input, task_group_id, task_id, task): +def cancel_all_action(parameters, graph_config, input, task_group_id, task_id, task): session = get_session() own_task_id = os.environ.get('TASK_ID', '') with futures.ThreadPoolExecutor(CONCURRENCY) as e: cancels_jobs = [ e.submit(cancel_task, t, use_proxy=True) for t in list_group(task_group_id, session) if t != own_task_id ] for job in cancels_jobs:
--- a/taskcluster/taskgraph/actions/purge_caches.py +++ b/taskcluster/taskgraph/actions/purge_caches.py @@ -20,14 +20,14 @@ logger = logging.getLogger(__name__) symbol='purge-caches', description=( 'Purge any caches associated with this task ' 'across all workers of the same workertype as the task.' ), order=100, context=[{'worker-implementation': 'docker-worker'}] ) -def purge_caches_action(parameters, input, task_group_id, task_id, task): +def purge_caches_action(parameters, graph_config, input, task_group_id, task_id, task): if task['payload'].get('cache'): for cache in task['payload']['cache']: purge_cache(task['provisionerId'], task['workerType'], cache, use_proxy=True) else: logger.info('Task has no caches. Will not clear anything!')