(stream_name_map, edge, is_final_arg=False)
| 47 | |
| 48 | |
| 49 | def _format_input_stream_name(stream_name_map, edge, is_final_arg=False): |
| 50 | prefix = stream_name_map[edge.upstream_node, edge.upstream_label] |
| 51 | if not edge.upstream_selector: |
| 52 | suffix = '' |
| 53 | else: |
| 54 | suffix = ':{}'.format(edge.upstream_selector) |
| 55 | if is_final_arg and isinstance(edge.upstream_node, InputNode): |
| 56 | ## Special case: `-map` args should not have brackets for input |
| 57 | ## nodes. |
| 58 | fmt = '{}{}' |
| 59 | else: |
| 60 | fmt = '[{}{}]' |
| 61 | return fmt.format(prefix, suffix) |
| 62 | |
| 63 | |
| 64 | def _format_output_stream_name(stream_name_map, edge): |
no outgoing calls
no test coverage detected
searching dependent graphs…