Skip to content

Instantly share code, notes, and snippets.

View r39132's full-sized avatar

Sid Anand r39132

View GitHub Profile
@r39132
r39132 / gist:f9b6061e9311ff654dfd
Created February 10, 2016 18:40
Example Short Circuit Operator (Airflow)
from airflow.operators import ShortCircuitOperator, DummyOperator
from airflow.models import DAG
import airflow.utils
from datetime import datetime, timedelta
seven_days_ago = datetime.combine(datetime.today() - timedelta(7),
datetime.min.time())
args = {
'owner': 'airflow',
'start_date': seven_days_ago,
@r39132
r39132 / gist:b22671d0293cd7740b38
Last active February 10, 2016 06:37
Sample Test with S3_Key_Sensor
import os
from airflow import DAG
from airflow.operators import *
from datetime import datetime, timedelta
from datetime import date
START_DATE = datetime(2016, 2, 4, 0, 0, 0)
default_args = {
'owner':'sanand',