Export pipeline directives as a JSON to stdout
(self)
| 1463 | sys.stdout.write(json.dumps(params_json)) |
| 1464 | |
| 1465 | def export_directives(self): |
| 1466 | """Export pipeline directives as a JSON to stdout |
| 1467 | """ |
| 1468 | |
| 1469 | directives_json = {} |
| 1470 | |
| 1471 | # Skip first init process |
| 1472 | for p in self.processes[1:]: |
| 1473 | directives_json[p.template] = p.directives |
| 1474 | |
| 1475 | # Flush params json to stdout |
| 1476 | sys.stdout.write(json.dumps(directives_json)) |
| 1477 | |
| 1478 | def fetch_docker_tags(self): |
| 1479 | """ |