https://dagster.io/ logo
#ask-community
Title
# ask-community
m

Mark

07/13/2022, 7:13 AM
Hi team! I have dynamic graph of ops like this:
Copy code
op = prepare_marts()
messages = load_messages(op)
theme_map = load_theme_mapping()
messages\
    .map(classify_messages)\
    .map(lambda messages: save_message_themes(messages, theme_map))
It works well, but unfortunately dagster run all
classify_messages
ops firstly and after that starts executing
save_message_themes
for all outputs. Can I run it in such order:
classify_messages[part_1]->save_message_themes[part_1] --> classify_messages[part_2]->save_message_themes[part_2] --> ...
Thank you!
👍 1
y

yuhan

07/13/2022, 10:23 PM
Sounds pretty similar to the question right below I created a discussion with some code snippets to explain how to control the flow https://github.com/dagster-io/dagster/discussions/8871
❤️ 1
m

Mark

07/14/2022, 6:43 AM
@yuhan thank you!
❤️ 1