https://dagster.io/ logo
#dagster-support
Title
# dagster-support
t

Tony

12/02/2022, 3:42 PM
Hello! Is it possible for the ops spawned from a DynamicOutput to run as they are yielded, or does the DynamicOutput have to finish processing before all parallel tasks can execute?
To clarify, using the process directory example from the docs. Is it possible to use the DynamicOutput to run an op against each yielded file as soon as it is yielded instead of waiting for the entire directory to be crawled?
c

chris

12/02/2022, 5:09 PM
unfortunately no - the downstream ops will wait until all upstream deps have finished executing.
t

Tony

12/02/2022, 5:09 PM
That's unfortunate. Are there any suggested work arounds for accomplishing that?
c

chris

12/02/2022, 5:42 PM
hmm. One workaround is instead of using dynamic outputs, you actually just launch off entirely separate runs
so instead of yielding a dynamic output for each file in the directory, you send a run request
(via graphql or something)
t

Tony

12/02/2022, 6:31 PM
Thanks! I'll try giving that a try.
3 Views