example_job.yaml

---
# See https://docs.openstack.org/infra/jenkins-job-builder/
# and in particular
# https://docs.openstack.org/infra/jenkins-job-builder/publishers.html#publishers.postbuildscript

- job:
    name: 'test_upstream_job'

    wrappers:
      - credentials-binding:
          - username-password-separated:
              credential-id: test-jenkins-credentials
              username: JENKINS_USERNAME
              password: JENKINS_API_KEY

    parameters:
      - string:
          name: TEST_PARAMETER

    builders:
      - shell: git clone https://gist.github.com/734e31ba46cff18ec7a45b99cc791787.git

      - trigger-builds:
          - project: 'test_downstream_job'
            current-parameters: true
            parameter-factories:
              - factory: counterbuild
                from: 0
                to: 5
                step: 1
            block: true

    publishers:
      - conditional-publisher:
          - condition-kind: current-status
            condition-best: ABORTED
            condition-worst: ABORTED
            action:
              - postbuildscript:
                  script-only-if-succeeded: false
                  script-only-if-failed: false
                  mark-unstable-if-failed: false
                  builders:
                    - shell: ./734e31ba46cff18ec7a45b99cc791787/jenkins_postbuild_abort_downstream.py

jenkins_postbuild_abort_downstream.py

#!/usr/bin/env python2

import base64
import os
import re
import ssl
import urllib2


UPSTREAM_JOB_NAME = os.getenv('JOB_NAME')
UPSTREAM_BUILD_ID = os.getenv('BUILD_NUMBER')
JENKINS_URL = os.getenv('JENKINS_URL').rstrip('/')
JENKINS_USER = os.getenv('JENKINS_USER') or os.getenv('JENKINS_USERNAME')
JENKINS_TOKEN = os.getenv('JENKINS_API_TOKEN') or os.getenv('JENKINS_API_KEY')

ENCODED_TOKEN = base64.b64encode('%s:%s' % (JENKINS_USER, JENKINS_TOKEN)).decode('ascii')
HEADERS = {
    'Authorization': 'Basic %s' % ENCODED_TOKEN,
}


def send_jenkins_request(location, request_data=None, method='GET'):
    request_url = location if JENKINS_URL in location else JENKINS_URL + location
    response_string = ''
    if method != 'GET' and request_data is None:
        # if data is not None then POST method will be used
        # https://docs.python.org/2/library/urllib2.html#urllib2.Request
        request_data = {}
    try:
        if request_url.startswith('https'):
            # https://docs.python.org/3/library/ssl.html#ssl-security
            context = ssl.create_default_context()
            context.load_default_certs()
        else:
            context = None
        req = urllib2.Request(request_url, data=request_data, headers=HEADERS)
        urlconn = urllib2.urlopen(req, context=context)
        response_string = urlconn.read()
        response_code = urlconn.getcode()
        urlconn.close()
    except urllib2.HTTPError as e:
        response_code = e.code

    print('url: {}\ncode: {}'.format(request_url, response_code))
    return response_string


def strip_xml_tags_and_split(txt, split_by='\n'):
    result = re.sub('<[^>]*>', split_by, txt)
    result = [i for i in result.split(split_by) if i]
    return result


# Find downstream jobs in a queue
#
# Response is like this::
#   <root>
#   <id>777</id>
#   </root>
url = (
    '/queue/api/xml'
    '?xpath=//*[action/cause/upstreamBuild[contains(text(),%s)]]/id'
    '&wrapper=root'
    % UPSTREAM_BUILD_ID
)
data = send_jenkins_request(url)
queue_ids = strip_xml_tags_and_split(data)
for qid in queue_ids:
    send_jenkins_request('/queue/cancelItem?id=%s' % qid, method='POST')


# Find downstream running jobs
#
# Response is like this::
#   <root>
#   <url>
#   http://my-jenkins.com/job/test-downstream-job/777
#   </url>
#   <url>
#   http://my-jenkins.com/job/rebuild-master-job/7
#   </url>
#   </root>
url = (
    '/computer/api/xml'
    '?tree=computer[executors[currentExecutable[url,actions[causes[*]]]]]'
    '&xpath=//*[action/cause/upstreamBuild[contains(text(),%s)]]/url'
    '&wrapper=root'
    % UPSTREAM_BUILD_ID
)
data = send_jenkins_request(url)
job_urls = strip_xml_tags_and_split(data)
for url in job_urls:
    # skip rebuilds jobs
    rebuild = '/job/%s/' % UPSTREAM_JOB_NAME
    if rebuild in url:
        print('Skip rebuild: %s' % url)
        continue
    send_jenkins_request('%sstop' % url, method='POST')