How does one guarantee that an op executes after all DynamicOuts ops conclude? Currently I have

items = get_items()
    items.map(tile_image)
    items.map(write_manifests)
    upload_collections(items.collect())

but this seems to trigger

upload_collections

immediately after resolving

write_manifests

inputs, not after it returns (I don’t need any data to

upload_collections

, it just needs to run when it’s all done). Also, does this code ensure that an

item

’s

tile_image

will conclude before it’s

write_manifests

starts?

you need to explicitly connect things you want to depend on each other, so in its most terse form:

upload_collections(get_items().map(tile_image).map(write_manifests).collect())

ah yes, didn’t realize I could

map

that way