Commit f525d6c2 authored by Domenico Giordano's avatar Domenico Giordano
Browse files

clean code

parent 2a28a260
......@@ -123,9 +123,6 @@ def ad_etl_dag(dag_id='give_me_a_name', override_params={}):
# Finally cache data locally (#FIXME what does it mean?)
spark_etl_to_hdfs >> from_hdfs_to_local
# computenormalization >> collect_failures
# downloaddata >> collect_failures
from_hdfs_to_local >> dag_exit_status
#collect_failures >> dag_exit_status
return dag
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment