SHARE
TWEET

Untitled

a guest Jul 19th, 2019 60 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
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!
 
Top