Export pipeline params as a JSON to stdout This run mode iterates over the pipeline processes and exports the params dictionary of each component as a JSON to stdout.
(self)
| 1447 | fh.write(pipeline_to_json) |
| 1448 | |
| 1449 | def export_params(self): |
| 1450 | """Export pipeline params as a JSON to stdout |
| 1451 | |
| 1452 | This run mode iterates over the pipeline processes and exports the |
| 1453 | params dictionary of each component as a JSON to stdout. |
| 1454 | """ |
| 1455 | |
| 1456 | params_json = {} |
| 1457 | |
| 1458 | # Skip first init process |
| 1459 | for p in self.processes[1:]: |
| 1460 | params_json[p.template] = p.params |
| 1461 | |
| 1462 | # Flush params json to stdout |
| 1463 | sys.stdout.write(json.dumps(params_json)) |
| 1464 | |
| 1465 | def export_directives(self): |
| 1466 | """Export pipeline directives as a JSON to stdout |