| 614 | } |
| 615 | |
| 616 | Expected<DataProcessorService::TransformRecipe> DataProcessorService::upsertTransform( |
| 617 | std::string_view plugin_id, std::string_view id, std::vector<std::string> inputs, std::vector<std::string> outputs, |
| 618 | std::string_view script, std::string_view params_json, bool ephemeral, std::size_t input_column_index) { |
| 619 | TransformRecipe recipe; |
| 620 | recipe.key = makeTransformKey(plugin_id, id); |
| 621 | recipe.owner_plugin = std::string(plugin_id); |
| 622 | recipe.user_id = std::string(id); |
| 623 | recipe.inputs = std::move(inputs); |
| 624 | recipe.outputs = std::move(outputs); |
| 625 | recipe.script = std::string(script); |
| 626 | recipe.params_json = std::string(params_json); |
| 627 | recipe.ephemeral = ephemeral; |
| 628 | recipe.input_column_index = input_column_index; |
| 629 | return installTransform(std::move(recipe)); |
| 630 | } |
| 631 | |
| 632 | Status DataProcessorService::removeTransform(std::string_view namespaced_key) { |
| 633 | const auto it = transform_recipes_.find(std::string(namespaced_key)); |