Move email notification from the listener to the agents - #6708

[taskcluster 2026-09-01T22:16:04.671Z] Worker Type (proj-bugbug/batch) settings:
[taskcluster 2026-09-01T22:16:04.671Z]   {
[taskcluster 2026-09-01T22:16:04.671Z]     "generic-worker": {
[taskcluster 2026-09-01T22:16:04.671Z]       "config": {
[taskcluster 2026-09-01T22:16:04.671Z]         "headlessTasks": false
[taskcluster 2026-09-01T22:16:04.671Z]       },
[taskcluster 2026-09-01T22:16:04.671Z]       "engine": "multiuser",
[taskcluster 2026-09-01T22:16:04.671Z]       "go-arch": "amd64",
[taskcluster 2026-09-01T22:16:04.671Z]       "go-os": "linux",
[taskcluster 2026-09-01T22:16:04.671Z]       "go-version": "go1.26.2",
[taskcluster 2026-09-01T22:16:04.671Z]       "release": "https://github.com/taskcluster/taskcluster/releases/tag/v99.1.0",
[taskcluster 2026-09-01T22:16:04.671Z]       "revision": "c76d61efe4bdc1a05bcec848739cd41ebf061f01",
[taskcluster 2026-09-01T22:16:04.671Z]       "source": "https://github.com/taskcluster/taskcluster/commits/c76d61efe4bdc1a05bcec848739cd41ebf061f01",
[taskcluster 2026-09-01T22:16:04.671Z]       "version": "99.1.0"
[taskcluster 2026-09-01T22:16:04.671Z]     },
[taskcluster 2026-09-01T22:16:04.671Z]     "image": "projects/community-tc-workers/global/images/generic-worker-ubuntu-24-04-aaynirqnxlbwcojgnbeo",
[taskcluster 2026-09-01T22:16:04.671Z]     "instance-id": "7055515575287241719",
[taskcluster 2026-09-01T22:16:04.671Z]     "instance-type": "projects/757942385826/machineTypes/n2-standard-2",
[taskcluster 2026-09-01T22:16:04.671Z]     "local-ipv4": "10.150.15.193",
[taskcluster 2026-09-01T22:16:04.671Z]     "machine-setup": {

...(61 lines hidden)...

[INFO] Initializing environment for https://github.com/pre-commit/mirrors-prettier.
[INFO] Initializing environment for https://github.com/pre-commit/mirrors-prettier:prettier@3.1.0.
[INFO] Initializing environment for https://github.com/astral-sh/ruff-pre-commit.
[INFO] Initializing environment for https://github.com/pre-commit/pre-commit-hooks.
[INFO] Initializing environment for https://github.com/codespell-project/codespell.
[INFO] Initializing environment for https://github.com/marco-c/taskcluster_yml_validator.
[INFO] Initializing environment for https://github.com/asottile/yesqa.
[INFO] Initializing environment for https://github.com/pre-commit/mirrors-mypy.
[INFO] Initializing environment for https://github.com/pre-commit/mirrors-mypy:types-pkg_resources==0.1.2,types-python-dateutil==2.9.0.20260716,types-PyYAML==6.0.12.20260724,types-orjson==3.6.2,types-tabulate==0.10.0.20260508,types-requests==2.33.0.20260712.
[INFO] Initializing environment for https://github.com/pre-commit/mirrors-mypy:types-pkg_resources==0.1.2,types-requests==2.33.0.20260712,types-Flask==1.1.6,types-redis==4.6.0.20241004,types-python-dateutil==2.9.0.20260716,types-orjson==3.6.2,types-tabulate==0.10.0.20260508.
[INFO] Installing environment for https://github.com/pre-commit/mirrors-prettier.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
[INFO] Installing environment for https://github.com/astral-sh/ruff-pre-commit.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
[INFO] Installing environment for https://github.com/pre-commit/pre-commit-hooks.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
[INFO] Installing environment for https://github.com/codespell-project/codespell.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
[INFO] Installing environment for https://github.com/marco-c/taskcluster_yml_validator.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
[INFO] Installing environment for https://github.com/asottile/yesqa.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
[INFO] Installing environment for https://github.com/pre-commit/mirrors-mypy.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
[INFO] Installing environment for https://github.com/pre-commit/mirrors-mypy.
[INFO] Once installed this environment will be reused.
[INFO] This may take a few minutes...
prettier.................................................................Passed
ruff check...............................................................Passed
ruff format..............................................................Passed
check python ast.........................................................Passed
check docstring is first.................................................Passed
check that executables have shebangs.....................................Passed
check for merge conflicts................................................Passed
check for broken symlinks............................(no files to check)Skipped
debug statements (python)................................................Passed
trim trailing whitespace.................................................Passed
check yaml...............................................................Passed
mixed line ending........................................................Passed
python tests naming......................................................Passed
check json...............................................................Passed
check vcs permalinks.....................................................Passed
codespell................................................................Passed
taskcluster_yml..........................................................Failed
- hook id: taskcluster_yml
- exit code: 1

Traceback (most recent call last):
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/referencing/_core.py", line 428, in get_or_retrieve
    resource = registry._retrieve(uri)
               ^^^^^^^^^^^^^^^^^^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/validators.py", line 113, in _warn_for_remote_retrieve
    with urlopen(request) as response:  # noqa: S310
         ^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/urllib/request.py", line 215, in urlopen
    return opener.open(url, data, timeout)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/urllib/request.py", line 521, in open
    response = meth(req, response)
               ^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/urllib/request.py", line 630, in http_response
    response = self.parent.error(
               ^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/urllib/request.py", line 559, in error
    return self._call_chain(*args)
           ^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/urllib/request.py", line 492, in _call_chain
    result = func(*args)
             ^^^^^^^^^^^
  File "/usr/local/lib/python3.12/urllib/request.py", line 639, in http_error_default
    raise HTTPError(req.full_url, code, msg, hdrs, fp)
urllib.error.HTTPError: HTTP Error 503: Service Unavailable

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/referencing/_core.py", line 682, in lookup
    retrieved = self._registry.get_or_retrieve(uri)
                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/referencing/_core.py", line 435, in get_or_retrieve
    raise exceptions.Unretrievable(ref=uri) from error
referencing.exceptions.Unretrievable: 'https://community-tc.services.mozilla.com/schemas/queue/v1/task.json'

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/validators.py", line 463, in _validate_reference
    resolved = self._resolver.lookup(ref)
               ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/referencing/_core.py", line 686, in lookup
    raise exceptions.Unresolvable(ref=ref) from error
referencing.exceptions.Unresolvable: task.json#/properties/workerType

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/bin/taskcluster_yml_validator", line 6, in <module>
    sys.exit(main())
             ^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/taskcluster_yml_validator/__init__.py", line 107, in main
    validate(args.tcml)
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/taskcluster_yml_validator/__init__.py", line 77, in validate
    jsonschema.validate(instance=task, schema=task_schema)
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/validators.py", line 1330, in validate
    error = exceptions.best_match(validator.iter_errors(instance))
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/exceptions.py", line 475, in best_match
    best = next(errors, None)
           ^^^^^^^^^^^^^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/validators.py", line 384, in iter_errors
    for error in errors:
                 ^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/_keywords.py", line 296, in properties
    yield from validator.descend(
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/validators.py", line 432, in descend
    for error in errors:
                 ^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/_keywords.py", line 275, in ref
    yield from validator._validate_reference(ref=ref, instance=instance)
               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/root/.cache/pre-commit/repohnlqbnlh/py_env-python3.12/lib/python3.12/site-packages/jsonschema/validators.py", line 465, in _validate_reference
    raise exceptions._WrappedReferencingError(err) from err
jsonschema.exceptions._WrappedReferencingError: Unresolvable: task.json#/properties/workerType

Strip unnecessary `# noqa`s..............................................Passed
mypy-bugbug..............................................................Passed
mypy-bugbug-http.........................................................Passed
Check for useless excludes...............................................Passed
[taskcluster 2026-09-01T22:18:00.889Z]                        Exit Code: 1
[taskcluster 2026-09-01T22:18:00.889Z]                        User Time: 44.731ms
[taskcluster 2026-09-01T22:18:00.889Z]                      Kernel Time: 48.991ms
[taskcluster 2026-09-01T22:18:00.889Z]                        Wall Time: 1m52.578605857s
[taskcluster 2026-09-01T22:18:00.889Z]  Average Available System Memory: 6.33 GiB
[taskcluster 2026-09-01T22:18:00.889Z]       Average System Memory Used: 1.42 GiB
[taskcluster 2026-09-01T22:18:00.889Z]          Peak System Memory Used: 1.74 GiB
[taskcluster 2026-09-01T22:18:00.889Z]              Total System Memory: 7.75 GiB
[taskcluster 2026-09-01T22:18:00.889Z]                           Result: FAILED
[taskcluster 2026-09-01T22:18:00.890Z] === Task Finished ===
[taskcluster 2026-09-01T22:18:00.890Z] Task Duration: 1m52.582030384s
[taskcluster:error] exit status 1