python
airflow
jar
5 years, 1 month ago
from airflow import DAG
from airflow.operators import BashOperator
from datetime import datetime
import os
import sys
args = {
'owner': 'airflow',
'start_date': datetime(2017, 1, 27),
'provide_context': True
}
d = datetime(2019, 9, 1)
dag = DAG('usgs', start_date = d, schedule_interval = '@daily', default_args = args)
t_main = BashOperator(
task_id = 'usgs_fetch',
dag = dag,
bash_command = 'java -cp /mnt/c/Users/img/Documents/GitHub/backbone/target/example-1.0-SNAPSHOT.jar'
#params = {'class': 'FetchJSON', 'path': 'jars/example.jar'}
)
0 Comments
Please Login to Comment Here