| 546 | } |
| 547 | |
| 548 | processor *add_python_processor(flow *flow, processor_logic* logic) { |
| 549 | if (nullptr == flow || nullptr == logic) { |
| 550 | return nullptr; |
| 551 | } |
| 552 | auto lambda = [logic](core::ProcessSession *ps, core::ProcessContext *cx) { |
| 553 | logic(static_cast<processor_session*>(ps), static_cast<processor_context*>(cx)); // Meh, sorry for this |
| 554 | }; |
| 555 | auto proc = flow->addCallback(nullptr, lambda); |
| 556 | return static_cast<processor*>(proc.get()); |
| 557 | } |
| 558 | |
| 559 | flow * create_getfile(nifi_instance * instance, flow * parent_flow, GetFileConfig * c) { |
| 560 | static const std::string first_processor = "GetFile"; |
nothing calls this directly
no test coverage detected