(processor, reader=None)
| 56 | |
| 57 | |
| 58 | def make_processor(processor, reader=None): |
| 59 | if processor is None: |
| 60 | return lambda rec: rec |
| 61 | elif isinstance(processor, core.Net): |
| 62 | return NetProcessor(processor) |
| 63 | else: |
| 64 | if reader is not None and hasattr(processor, "schema_func"): |
| 65 | def processor_schema(): |
| 66 | return processor.schema_func(reader) |
| 67 | |
| 68 | processor.schema = processor_schema |
| 69 | return processor |
| 70 | |
| 71 | |
| 72 | def normalize_processor_output(output): |
no test coverage detected
searching dependent graphs…