with Flow("myflow") as flow:
			tasks...

            # push to datastore
            back_in_datastore = put_to_datastore(rezipped)

            # done
            final = alldone(back_in_datastore)