diff --git a/dags/veda_data_pipeline/veda_dataset_pipeline.py b/dags/veda_data_pipeline/veda_dataset_pipeline.py index c6b1f2b..117510c 100644 --- a/dags/veda_data_pipeline/veda_dataset_pipeline.py +++ b/dags/veda_data_pipeline/veda_dataset_pipeline.py @@ -79,7 +79,6 @@ def mutate_payload(**kwargs): @task(max_active_tis_per_dag=3) def transfer_assets_to_production_bucket(payload): - # TODO do transfer transfer_data(payload) # if transfer complete, update discovery payload to reflect new bucket payload.update({"bucket": "veda-data-store"})