# This Source Code Form is subject to the terms of the Mozilla Public # License, v. 2.0. If a copy of the MPL was not distributed with this # file, You can obtain one at http://mozilla.org/MPL/2.0/. """ Apply some defaults and minor modifications to the single_dep jobs. """ from __future__ import absolute_import, print_function, unicode_literals from taskgraph.transforms.base import TransformSequence from taskgraph.util.treeherder import inherit_treeherder_from_dep, join_symbol transforms = TransformSequence() @transforms.add def build_name_and_attributes(config, tasks): for task in tasks: dep = task["primary-dependency"] task["dependencies"] = {dep.kind: dep.label} copy_of_attributes = dep.attributes.copy() task.setdefault("attributes", copy_of_attributes) # run_on_tasks_for is set as an attribute later in the pipeline task.setdefault("run-on-tasks-for", copy_of_attributes['run_on_tasks_for']) task["name"] = _get_dependent_job_name_without_its_kind(dep) yield task def _get_dependent_job_name_without_its_kind(dependent_job): return dependent_job.label[len(dependent_job.kind) + 1:] @transforms.add def build_upstream_artifacts(config, tasks): for task in tasks: dep = task["primary-dependency"] worker_definition = {} worker_definition["upstream-artifacts"] = [{ "taskId": {"task-reference": "<{}>".format(dep.kind)}, "taskType": dep.kind, "paths": sorted(dep.attributes["apks"].values()), }] task["worker"].update(worker_definition) yield task @transforms.add def build_treeherder_definition(config, tasks): for task in tasks: dep = task.pop("primary-dependency") task.setdefault("treeherder", {}).update(inherit_treeherder_from_dep(task, dep)) job_group = dep.task["extra"]["treeherder"].get("groupSymbol", "?") job_symbol = task["treeherder"].pop("job-symbol") full_symbol = join_symbol(job_group, job_symbol) task["treeherder"]["symbol"] = full_symbol yield task