def print_hello():
        with open('/home/airflow/gcs/data/people.csv','rt')as f:
         data = csv.reader(f)
         for row in data:
             print(row)



def print_hello_1():
        with open('/home/airflow/gcs/data/people1.csv','rt')as f:
         data = csv.reader(f)
         for row in data:
              print(row)

t1 = PythonOperator(task_id='Raw1', python_callable=print_hello, dag=dag)
t2 = PythonOperator(task_id='Raw2', python_callable=print_hello_1, dag=dag)