(self, module, processor)
| 209 | return Processor(proc,self._minifi) |
| 210 | |
| 211 | def create_python_processor(self, module, processor): |
| 212 | m = getattr(module, processor)(self._minifi, self._flow) |
| 213 | proc = self._minifi.add_python_processor(self._flow, m.getTriggerCallback()) |
| 214 | m.setBase(proc) |
| 215 | return m |
| 216 | |
| 217 | def get_next_flowfile(self): |
| 218 | ff = self._minifi.get_next_flow_file(self._instance.get_instance(), self._flow) |
no test coverage detected