add workflow 天润Smart-ccc会话数据,dev

dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py

@@ -14,7 +14,7 @@ from airflow.utils.trigger_rule import TriggerRule
 
 sshHook = SSHHook(ssh_conn_id ='ssh_air')
 default_args = {
-'owner': 'info@idgvalue.com',
+'owner': 'tek_newsletter@163.com',
 'email_on_failure': True,
 'email_on_retry':True,
 'start_date': datetime(2024, 1, 1),
@@ -24,7 +24,7 @@ default_args = {
 }
 
 dag = DAG('wf_dag_smart_ccc_chat', default_args=default_args,
-schedule_interval="0 0-23/1 * * *",
+schedule_interval="0 8 * * *",
 catchup=False,
 dagrun_timeout=timedelta(minutes=160),
 max_active_runs=3)
@@ -33,7 +33,7 @@ task_failed = EmailOperator (
     dag=dag,
     trigger_rule=TriggerRule.ONE_FAILED,
     task_id="task_failed",
-    to=["info@idgvalue.com"],
+    to=["tek_newsletter@163.com"],
     cc=[""],
     subject="smart_ccc_chat_failed",
     html_content='<h3>您好，smart_ccc_chat作业失败，请及时处理" </h3>')
@@ -199,4 +199,6 @@ cust_leads >> cust_all_info
 cust_contact_info >> cust_all_info
 chat_records_n_load >> tr_chat_messages_new_2443
 chat_records_n_load >> tr_chat_records_new_9594
-tr_chat_records_new_9594 >> task_failed 
+tr_chat_messages_new_2443 >> t01_ccc_chat_message_detail
+tr_chat_records_new_9594 >> t01_ccc_chat_record
+t01_ccc_chat_record >> task_failed