(processor)
| 175 | |
| 176 | |
| 177 | def processor_name(processor): |
| 178 | if hasattr(processor, 'name'): |
| 179 | return processor.name |
| 180 | if hasattr(processor, 'func_name'): |
| 181 | if processor.func_name == '<lambda>': |
| 182 | return processor.__module__ |
| 183 | if hasattr(processor, 'im_class'): |
| 184 | return '%s.%s' % (processor.im_class.__name__, processor.func_name) |
| 185 | return processor.func_name |
| 186 | return processor.__class__.__name__ |
| 187 | |
| 188 | |
| 189 | def _runtime_threads_task(name, group, final_outputs, reader, num_threads, |
no outgoing calls
no test coverage detected
searching dependent graphs…