(c: Composition, parser: WorkflowArgumentParser)
| 105 | |
| 106 | |
| 107 | def workflow_default(c: Composition, parser: WorkflowArgumentParser) -> None: |
| 108 | |
| 109 | parser.add_argument("disruptions", nargs="*", default=[d.name for d in disruptions]) |
| 110 | |
| 111 | args = parser.parse_args() |
| 112 | |
| 113 | c.up("kafka", "schema-registry") |
| 114 | for id, disruption in enumerate(selected_by_name(args.disruptions, disruptions)): |
| 115 | run_test(c, disruption, id) |
| 116 | |
| 117 | |
| 118 | def populate(c: Composition) -> None: |
nothing calls this directly
no test coverage detected