adamhaney

from datetime import datetime, timedelta
import networkx as nx

from airflow import DAG
from airflow.operators import BashOperator, SubDagOperator

start_date = datetime(year=2017, month=6, day=13, hour=19, minute=0)
schedule_interval = '0 * * * 1-5'

default_args = {

adamhaney

adamhaney

def deploy():
    execute(__backup__)
    execute(__pull__)
    execute(__install_requirements__)
    execute(syncdb)
    execute(collectstatic)
    execute(restart)
    execute(newrelic)

adamhaney

#!/bin/bash
# pushup.sh
#
# Cron entry, weekdays on the hour from 8am-7pm
# m h  dom mon dow   command
# 0 8-19 * * 1-5 bash pushup.sh

# Minimum number of pushups you want to do
MINUPS=10

adamhaney

from multiprocessing import Pool
p = Pool()
p.map(lambda x: x, [1, 2, 3])