dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 泰克CRM,dev

This commit is contained in:
root 2024-06-13 10:31:36 +08:00
parent 06e84567d9
commit 3d99f5d499
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dev/workflow/TK_Cust/tk_crm/泰克CRM/wf_dag_tk_crm.py
View File

@ -7,8 +7,10 @@ from airflow.contrib.operators.ssh_operator import SSHOperator
from airflow.sensors.external_task_sensor import ExternalTaskSensor from airflow.sensors.external_task_sensor import ExternalTaskSensor
import json import json
from airflow.operators.trigger_dagrun import TriggerDagRunOperator
from airflow.operators.email_operator import EmailOperator from airflow.operators.email_operator import EmailOperator
from airflow.utils.trigger_rule import TriggerRule from airflow.utils.trigger_rule import TriggerRule
from airflow.operators.external_task_marker_operator import ExternalTaskMarker
sshHook = SSHHook(ssh_conn_id ='ssh_air') sshHook = SSHHook(ssh_conn_id ='ssh_air')