abridgett

MAP_SLACK_ATTACHMENTS = [
    {
        "fallback": "{{params.map}} {{ task_instance.xcom_pull(task_ids=params.map, key='slack_status') }}",
        "pretext": "{{params.map}} update {{ task_instance.xcom_pull(task_ids=params.map, key='slack_status') }}",
        "fields": [
            {
                "title": "Copied",
                "value": "{{ task_instance.xcom_pull(task_ids=params.map, key='copied') }}",
                "short": True
            }

jehiah

# Copyright Jehiah Czebotar 2013
# http://jehiah.cz/

import tornado.options
import glob
import os
import sqlite3
import logging
import datetime
import csv