"""Example Lambda Invocation."""

from datetime import datetime

from airflow import DAG
from airflow.operators.python import PythonOperator

from lib import constants
from tasks.example_lambda.invoke_example_lambda import invoke_example_lambda_callback

dag = DAG(
    constants.DAG_EXAMPLE_EVENT_NAME,
    description='Invoke an example lambda',
    start_date=datetime(2019, 1, 1),
    default_args={'provide_context': True},
    schedule_interval=None
)


"""
######################################################################
############################# OPERATORS ##############################
######################################################################
"""


invoke_example_lambda_operator = PythonOperator(
    task_id='invoke_transaction_processor',
    python_callable=invoke_example_lambda_callback,
    dag=dag
)


"""
######################################################################
################################ DAG #################################
######################################################################
"""

invoke_example_lambda_operator