from airflow import DAG from airflow.operators.python_operator import PythonOperator from datetime import datetime, timedelta import boto3, json, time glue_client = boto3.client('glue', region_name='us-east-1') default_args = { 'owner': 'SAM', 'start_date': datetime(2019, 5, 27) # days_ago(n=1) } default_schedule_interval = "0 15 * * *" # '@daily' def run_customer_job(random_base): job = glue_cl..