tmehlinger

from __future__ import with_statement
from kombu import BrokerConnection
from collections import defaultdict
import gevent
from gevent import monkey
monkey.patch_all()

class WorkerHub():
    """
    WorkerHub controls the local mailboxes that the @worker decorator assigns.

tmehlinger

#!/bin/bash
# This hook is sourced after a new virtualenv is activated.

POST_INSTALL_PKGS="pylint pudb"
PIP=$(which pip)

$PIP install $POST_INSTALL_PKGS

tmehlinger

Internet Scale Services Checklist

A checklist for designing and developing internet scale services, inspired by James Hamilton's 2007 paper "On Desgining and Deploying Internet-Scale Services."

• http://mvdirona.com/jrh/talksandpapers/jamesrh_lisa.pdf

Basic tenets

• Does the design expect failures to happen regularly and handle them gracefully?
• Have we kept things as simple as possible?

tmehlinger

#!/usr/bin/env python3.4

from itertools import tee
from random import randint, shuffle
import sys


def pairwise(iterable):
    "s -> (s0,s1), (s1,s2), (s2, s3), ..."
    a, b = tee(iterable)

tmehlinger

# -*- coding: utf-8 -*-
'''
Decrypt secrets in pillar data using AWS KMS.

This module uses boto3 to connect to KMS and decrypt secrets in pillar data
using keys stored in KMS. It will recurse the supplied pillar data, scanning
for any keys marked by the configured delimiter. If it finds any interesting
keys, it will communicate with KMS to decrypt the respective values with the
suppled key ID.

tmehlinger

#!/bin/bash

URL=$1
DYNAMODB_PATH=$2
FULL_URL=$(curl -sI $1 | awk '/Location/{gsub(/Location: /, ""); print}')
LATEST_VERSION=$(echo $FULL_URL | cut -d _ -f 3 | sed 's/\..*//')
VERSION_FILE=$2/VERSION
INSTALLED_VERSION=$([[ -f $VERSION_FILE ]] && cat $VERSION_FILE || echo "NOT INSTALLED")

# if we couldn't extract location from headers (i.e., there's a problem with

tmehlinger

import distutils.util
import functools
import inspect

from fabric.decorators import task


class bool_args(object):
    def __init__(self, *bool_arg_names):
        self.bool_arg_names = bool_arg_names

tmehlinger

from collections import defaultdict
import json
import logging

import salt.minion
import salt.utils
import salt.utils.event


log = logging.getLogger(__name__)

tmehlinger

from collections.abc import Iterable


def flatten(seq, maxdepth=10):
    if maxdepth <= 0:
        raise ValueError
    if isinstance(seq, Iterable) and not isinstance(seq, str):
        for item in seq:
            yield from flatten(item, maxdepth - 1)
    else:

tmehlinger

@pytest.fixture
def GroupFixture():
    def wrapper(name='Test Group'):
        return Group(name=name)
    return wrapper


@pytest.fixture
def UserFixture():
    def wrapper(groups=None):