ulises

When you cancel a Jenkins job

Unfinished draft; do not use until this notice is removed.

We were seeing some unexpected behavior in the processes that Jenkins launches when the Jenkins user clicks "cancel" on their job. Unexpected behaviors like:

• apparently stale lockfiles and pidfiles
• overlapping processes
• jobs apparently ending without performing cleanup tasks
• jobs continuing to run after being reported "aborted"

ulises

Keybase proof

I hereby claim:

• I am ulises on github.
• I am ulises_cervino (https://keybase.io/ulises_cervino) on keybase.
• I have a public key ASCDiqrIlfSPDT8ARR64BJBVZys-tgRkYiFiHde9LKuykAo

To claim this, I am signing this object:

ulises

#!/usr/bin/python

import requests
import json
import argparse
from Queue import Queue
from threading import Thread, Lock
import sys
import unicodedata

ulises

Ansible Logging To Elasticsearch

Turns Ansible log outputs into plain JSON strings and sends them to an Elasticsearch cluster.

Place the script in your playbook's plugins/callbacks/ directory.

ulises

#####################################################################
#
# This script starts an automatically recorded session using `script`
# storing logs in `$log_dir`. Care should be taken to secure records
# generated by this script as they may easily contain passwords and
# other sensistive information.
#
#####################################################################

# FIXME(bh): make this configurable

ulises

    nodes = resp.json()['nodes']
    ret = []
    for id, node in nodes.items():
        node.update({'id': id})
        ret.append(node)

    return ret

ulises

# from http://codereview.stackexchange.com/questions/42802/a-non-blocking-lock-decorator-in-python
def non_blocking_lock(fn):
    """Decorator. Prevents the function from being called multiple times simultaneously.

    If thread A is executing the function and thread B attempts to call the
    function, thread B will immediately receive a return value of None instead.

    """
    locks = defaultdict(Lock)

ulises

(import [flask [Flask]])

(def app (Flask "hy-flask"))
;; (import [app [views]])

(with-decorator (.route app "/")
  (defn index [] "hello!"))

ulises

@app.route('/status/<runid>')
def testy_run_status(runid):
    toasty_root = "/Users/ulises/development/testy/toasty"

    print "Checking: " + runid

    def read_status():
        line = ""
        with io.open(toasty_root + "/runs/" + str(runid), "r") as f:
            while not summary.findall(line):

ulises

def run(exe):
    p = Popen(exe, stdout=PIPE, stderr=STDOUT)
    while(True):
        retcode = p.poll() #returns None while subprocess is running
        line = p.stdout.readline()
        yield line
        if(retcode is not None):
            break