| 709 | } |
| 710 | |
| 711 | std::vector<DataProcessorService::TransformRecipe> DataProcessorService::transformRecipes() const { |
| 712 | std::vector<TransformRecipe> out; |
| 713 | out.reserve(transform_recipes_.size()); |
| 714 | for (const auto& [key, recipe] : transform_recipes_) { |
| 715 | (void)key; |
| 716 | if (recipe.ephemeral) { |
| 717 | continue; // preview node — never persisted |
| 718 | } |
| 719 | out.push_back(recipe); |
| 720 | } |
| 721 | return out; |
| 722 | } |
| 723 | |
| 724 | std::unordered_set<TopicId> DataProcessorService::ephemeralOutputTopics() const { |
| 725 | std::unordered_set<TopicId> out; |