from airflow import DAG
from datetime import datetime, timedelta
from airflow.providers.amazon.aws.operators.glue import AwsGlueJobOperator

default_args = {
	"owner": "airflow-user",
	"start_date": datetime.today(),
	"depends_on_past": False,
	"email_on_failure": False,
	"email_on_retry": False,
	"email": "<your-email-address>",
	"retries": 1,
	"retry_delay": timedelta(minutes=5)
}

with DAG(dag_id="start-glue-job", schedule_interval="@daily", default_args=default_args, catchup=False) as dag:
	glue_job = AwsGlueJobOperator(
		task_id='my_glue_job',
		job_name='<your-Glue-job-name>',
		num_of_dpus=5,
		region_name='<region>'
	)
