Update alarm_kafka_connect.py

dags/kafka/alarm_kafka_connect.py

@@ -13,8 +13,8 @@ import airflow
 
 #variable parameter
 DAG_ID = 'alarm_kafka_connect'
-START_DATE = datetime.now() - timedelta(minutes=10)
-SCHEDULE_INTERVAL = timedelta(minutes=5)
+START_DATE = datetime.now() - timedelta(minutes=30)
+SCHEDULE_INTERVAL = timedelta(minutes=15)
 
 SERVICES = [
 'es-gmei-test-cp-kafka-connect',
@@ -52,6 +52,8 @@ default_args = {
     'owner': 'tangxianggang',
     'depends_on_past': False,
     'start_date': START_DATE,
+    'retries': 3,
+    'retry_delay': timedelta(seconds=5)
 }
 
 dag = DAG(