From 65f79e9dc9f76ca8bb5b8f64544a25c13016c8af Mon Sep 17 00:00:00 2001 From: Keerthana Date: Mon, 22 Feb 2021 13:37:23 +0530 Subject: [PATCH 1/2] newfile --- main/listchanneldag.py | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 main/listchanneldag.py diff --git a/main/listchanneldag.py b/main/listchanneldag.py new file mode 100644 index 0000000..bc4266c --- /dev/null +++ b/main/listchanneldag.py @@ -0,0 +1,23 @@ +from airflow import DAG +from airflow.operators import BashOperator,PythonOperator +from datetime import datetime, timedelta +import json +from airflow.models import Variable +from listchannelpy import webhook + + +default_args = { + 'owner': 'airflow', + 'depends_on_past': False, + 'start_date': datetime(2020, 3, 3), + 'retries': 1, + 'retry_delay': timedelta(minutes=5), + + } + +dag = DAG('daglistchannel', default_args=default_args) +t1 = BashOperator( + task_id='testslack', + bash_command="python /Users/keerthana/airflow/dags/listchannelpy.py ", + xcom_push=True, + dag=dag) From 9556e6b724906569d26523b846afc1c7f355719e Mon Sep 17 00:00:00 2001 From: Keerthana Date: Mon, 22 Feb 2021 13:56:50 +0530 Subject: [PATCH 2/2] newfile --- main/jsconfig.json | 6 ++++++ main/listchanneldag.py | 23 ----------------------- 2 files changed, 6 insertions(+), 23 deletions(-) create mode 100644 main/jsconfig.json delete mode 100644 main/listchanneldag.py diff --git a/main/jsconfig.json b/main/jsconfig.json new file mode 100644 index 0000000..5875dc5 --- /dev/null +++ b/main/jsconfig.json @@ -0,0 +1,6 @@ +{ + "compilerOptions": { + "baseUrl": "src" + }, + "include": ["src"] +} diff --git a/main/listchanneldag.py b/main/listchanneldag.py deleted file mode 100644 index bc4266c..0000000 --- a/main/listchanneldag.py +++ /dev/null @@ -1,23 +0,0 @@ -from airflow import DAG -from airflow.operators import BashOperator,PythonOperator -from datetime import datetime, timedelta -import json -from airflow.models import Variable -from listchannelpy import webhook - - -default_args = { - 'owner': 'airflow', - 'depends_on_past': False, - 'start_date': datetime(2020, 3, 3), - 'retries': 1, - 'retry_delay': timedelta(minutes=5), - - } - -dag = DAG('daglistchannel', default_args=default_args) -t1 = BashOperator( - task_id='testslack', - bash_command="python /Users/keerthana/airflow/dags/listchannelpy.py ", - xcom_push=True, - dag=dag)