(c: Composition, parser: WorkflowArgumentParser)
| 351 | |
| 352 | |
| 353 | def workflow_cdc(c: Composition, parser: WorkflowArgumentParser) -> None: |
| 354 | pg_version = get_targeted_pg_version(parser) |
| 355 | |
| 356 | parser.add_argument( |
| 357 | "filter", |
| 358 | nargs="*", |
| 359 | default=["*.td"], |
| 360 | help="limit to only the files matching filter", |
| 361 | ) |
| 362 | args = parser.parse_args() |
| 363 | |
| 364 | sharded_files = [ |
| 365 | file for file in get_sharded_files(args.filter) if file != "exclude-columns.td" |
| 366 | ] |
| 367 | print(f"Files: {sharded_files}") |
| 368 | ssl_args_dict = get_testdrive_ssl_args(c) |
| 369 | testdrive_ssl_args = ssl_args_dict["testdrive_args"] |
| 370 | |
| 371 | testdrive_args = testdrive_ssl_args + get_default_testdrive_size_args() |
| 372 | with c.override(create_postgres(pg_version=pg_version)): |
| 373 | c.up("materialized", "test-certs", "postgres") |
| 374 | c.test_parts( |
| 375 | sharded_files, |
| 376 | lambda file: c.run_testdrive_files( |
| 377 | *testdrive_args, |
| 378 | file, |
| 379 | ), |
| 380 | ) |
| 381 | |
| 382 | |
| 383 | def workflow_default(c: Composition, parser: WorkflowArgumentParser) -> None: |
nothing calls this directly
no test coverage detected