Bug 1418058: [taskcluster] Add `graph_config` to some actions that were originally missed; r=dustin
authorTom Prince <mozilla@hocat.ca>
Mon, 23 Apr 2018 13:08:28 -0600
changeset 415656 51c27d9d25eaca9db40ef561bd3f9cdab63bf9b0
parent 415655 f864f16fdd38b52e30ce5d064b4f8c1c0fb8ae9e
child 415657 1527cfbcd067b594afc71fc2a7673f5bffed1a94
push id33901
push userapavel@mozilla.com
push dateThu, 26 Apr 2018 06:05:37 +0000
treeherdermozilla-central@b62ad926cf2a [default view] [failures only]
perfherder[talos] [build metrics] [platform microbench] (compared to previous push)
reviewersdustin
bugs1418058
milestone61.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
Bug 1418058: [taskcluster] Add `graph_config` to some actions that were originally missed; r=dustin Differential Revision: https://phabricator.services.mozilla.com/D1025
taskcluster/taskgraph/actions/cancel_all.py
taskcluster/taskgraph/actions/purge_caches.py
--- 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!')