Guest User

Untitled

a guest
Jul 19th, 2019
64
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. def print_hello():
  2. with open('/home/airflow/gcs/data/people.csv','rt')as f:
  3. data = csv.reader(f)
  4. for row in data:
  5. print(row)
  6.  
  7.  
  8.  
  9. def print_hello_1():
  10. with open('/home/airflow/gcs/data/people1.csv','rt')as f:
  11. data = csv.reader(f)
  12. for row in data:
  13. print(row)
  14.  
  15. t1 = PythonOperator(task_id='Raw1', python_callable=print_hello, dag=dag)
  16. t2 = PythonOperator(task_id='Raw2', python_callable=print_hello_1, dag=dag)
RAW Paste Data