Skip to content

Instantly share code, notes, and snippets.

@tarsisazevedo
Created December 20, 2016 19:17
Show Gist options
  • Save tarsisazevedo/49b6462cc530c363ae929a44c2931e42 to your computer and use it in GitHub Desktop.
Save tarsisazevedo/49b6462cc530c363ae929a44c2931e42 to your computer and use it in GitHub Desktop.
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators import PythonOperator
start_date = datetime.now()
default_args = {
'owner': 'ab-analytics',
'depends_on_past': False,
'start_date': start_date,
'email': ['x@example.com'],
'email_on_failure': True,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(seconds=30)
}
dag = DAG('false-check', schedule_interval='*/30 * * * *', default_args=default_args)
def return_false(*args, **kwargs):
return False
PythonOperator(
python_callable=return_false,
task_id='check',
provide_context=True,
dag=dag,
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment