Coverage for airflow.macros : 65%

from __future__ import absolute_import 

from random import random 

from datetime import datetime, timedelta 

import time 

from . import hive 

import uuid 

def ds_add(ds, days): 

    """ 

    Add or subtract days from a YYYY-MM-DD 

    :param ds: anchor date in ``YYYY-MM-DD`` format to add to 

    :type ds: str 

    :param days: number of days to add to the ds, you can use negative values 

    :type days: int 

    >>> ds_add('2015-01-01', 5) 

    '2015-01-06' 

    >>> ds_add('2015-01-06', -5) 

    '2015-01-01' 

    """ 

    ds = datetime.strptime(ds, '%Y-%m-%d') 

    if days: 

        ds = ds + timedelta(days) 

    return ds.isoformat()[:10] 

def ds_format(ds, input_format, output_format): 

    """ 

    Takes an input string and outputs another string 

    as specified in the output format 

    :param ds: input string which contains a date 

    :type ds: str 

    :param input_format: input string format. E.g. %Y-%m-%d 

    :type input_format: str 

    :param output_format: output string format  E.g. %Y-%m-%d 

    :type output_format: str 

    >>> ds_format('2015-01-01', "%Y-%m-%d", "%m-%d-%y") 

    '01-01-15' 

    >>> ds_format('1/5/2015', "%m/%d/%Y",  "%Y-%m-%d") 

    '2015-01-05' 

    """ 

    return datetime.strptime(ds, input_format).strftime(output_format) 

def integrate_plugins(): 

    """Integrate plugins to the context""" 

    from airflow.plugins_manager import macros as _macros 

    for _macro in _macros: 

        globals()[_macro.__name__] = _macro