diff --git a/dags/just_reg.py b/dags/just_reg.py index 827eef9a82cfe77a2c9a44d5ddfa5bc6bd9ffa2b..0f4af0b9c4af413d53e20085f60a7f1428e9c359 100644 --- a/dags/just_reg.py +++ b/dags/just_reg.py @@ -85,12 +85,13 @@ def datacat_registration_example(): - step1 = BashOperator(bash_command='ls', task_id='nothing') + step1 = BashOperator(bash_command='curl -X GET -k https://bscgrid20.bsc.es/image_creation/images/download/wordcount_skylake.sif -o /work/ww', task_id='nothing') step2 = register( object_url='https://b2share-testing.fz-juelich.de/records/7a12fda26b2a4d248f96d012d54769b7') step3 = get_template() - step1 >> step2 >> step3 + stepr = BashOperator(bash_command='rm /work/ww', task_id='nothing') + step1 >> step2 >> step3 >> stepr dag = datacat_registration_example() diff --git a/dags/uploadflow.py b/dags/uploadflow.py index 4ceacb99bef508f0028bdc98a30f8c8c661b6e2b..17c845bcb56bff1b3b5df3d6404cf4ac6f87431c 100644 --- a/dags/uploadflow.py +++ b/dags/uploadflow.py @@ -152,7 +152,7 @@ def upload_example(): reg = register(object_url=uid) - setup_task >> files >> uid >> en + setup_task >> files >> uid >> reg >> en dag = upload_example()