(c: Composition, parser: WorkflowArgumentParser)
| 209 | |
| 210 | |
| 211 | def workflow_default(c: Composition, parser: WorkflowArgumentParser) -> None: |
| 212 | # c.silent = True |
| 213 | parser.add_argument( |
| 214 | "--scenario", metavar="SCENARIO", type=str, help="Scenario to run." |
| 215 | ) |
| 216 | |
| 217 | parser.add_argument( |
| 218 | "--check", metavar="CHECK", type=str, action="append", help="Check(s) to run." |
| 219 | ) |
| 220 | |
| 221 | parser.add_argument( |
| 222 | "--execution-mode", |
| 223 | type=ExecutionMode, |
| 224 | choices=list(ExecutionMode), |
| 225 | default=ExecutionMode.SEQUENTIAL, |
| 226 | ) |
| 227 | |
| 228 | parser.add_argument( |
| 229 | "--seed", |
| 230 | metavar="SEED", |
| 231 | type=str, |
| 232 | help="Seed for shuffling checks in sequential run.", |
| 233 | ) |
| 234 | |
| 235 | parser.add_argument( |
| 236 | "--system-param", |
| 237 | type=str, |
| 238 | action="append", |
| 239 | nargs="*", |
| 240 | help="System parameters to set in Materialize, i.e. what you would set with `ALTER SYSTEM SET`", |
| 241 | ) |
| 242 | |
| 243 | parser.add_argument( |
| 244 | "--features", |
| 245 | nargs="*", |
| 246 | help="A list of features (e.g. azurite), to enable.", |
| 247 | ) |
| 248 | |
| 249 | parser.add_argument( |
| 250 | "--default-replication-factor", |
| 251 | type=int, |
| 252 | default=2, |
| 253 | help="Default replication factor for clusters", |
| 254 | ) |
| 255 | |
| 256 | parser.add_argument( |
| 257 | "--external-metadata-store", action=argparse.BooleanOptionalAction, default=True |
| 258 | ) |
| 259 | parser.add_argument( |
| 260 | "--external-blob-store", action=argparse.BooleanOptionalAction, default=True |
| 261 | ) |
| 262 | |
| 263 | args = parser.parse_args() |
| 264 | features = Features(args.features) |
| 265 | |
| 266 | if args.scenario: |
| 267 | assert args.scenario in globals(), f"scenario {args.scenario} does not exist" |
| 268 | scenarios = [globals()[args.scenario]] |
nothing calls this directly
no test coverage detected