Here is what I am trying to do exactly: https://gist.github.com/praveev/7b93b50746f8e965f7139ecba028490a
the python operator log just returns the following
INFO - Executing <Task(PythonOperator): run_distcp_on_each> on 2016-04-28 11:56:12
INFO - Done. Returned value was: None
it didn't even print my kwargs and to_process data
To simplify this. Lets say t1 returns 3 elements. I want to iterate over the list and run t2 -> t3 for each element.