(c: Composition, parser: WorkflowArgumentParser)
| 514 | |
| 515 | |
| 516 | def workflow_default(c: Composition, parser: WorkflowArgumentParser) -> None: |
| 517 | parser.add_argument("disruptions", nargs="*", default=[d.name for d in disruptions]) |
| 518 | |
| 519 | args = parser.parse_args() |
| 520 | |
| 521 | sharded_disruptions = buildkite.shard_list( |
| 522 | list(selected_by_name(args.disruptions, disruptions)), lambda s: s.name |
| 523 | ) |
| 524 | print( |
| 525 | f"Disruptions in shard with index {buildkite.get_parallelism_index()}: {[d.name for d in sharded_disruptions]}" |
| 526 | ) |
| 527 | for disruption in sharded_disruptions: |
| 528 | c.override_current_testcase_name( |
| 529 | f"Disruption '{disruption.name}' in workflow_default" |
| 530 | ) |
| 531 | disruption.run_test(c) |
| 532 | c.down(sanity_restart_mz=False) |
| 533 | |
| 534 | |
| 535 | def delete_sink_topic(c: Composition, seed: int) -> None: |
nothing calls this directly
no test coverage detected