(
threads,
processes,
first_port,
addresses,
process_id,
record,
record_path,
repository_url,
branch,
program,
arguments,
)
| 367 | @click.argument("program") |
| 368 | @click.argument("arguments", nargs=-1) |
| 369 | def spawn( |
| 370 | threads, |
| 371 | processes, |
| 372 | first_port, |
| 373 | addresses, |
| 374 | process_id, |
| 375 | record, |
| 376 | record_path, |
| 377 | repository_url, |
| 378 | branch, |
| 379 | program, |
| 380 | arguments, |
| 381 | ): |
| 382 | processes, process_id = validate_and_resolve_spawn_args( |
| 383 | threads=threads, |
| 384 | processes=processes, |
| 385 | first_port=first_port, |
| 386 | addresses=addresses, |
| 387 | process_id=process_id, |
| 388 | ) |
| 389 | env = os.environ.copy() |
| 390 | if record: |
| 391 | env["PATHWAY_REPLAY_STORAGE"] = record_path |
| 392 | env["PATHWAY_SNAPSHOT_ACCESS"] = "record" |
| 393 | env["PATHWAY_CONTINUE_AFTER_REPLAY"] = "true" |
| 394 | spawn_program( |
| 395 | threads=threads, |
| 396 | processes=processes, |
| 397 | first_port=first_port, |
| 398 | addresses=addresses, |
| 399 | process_id=process_id, |
| 400 | repository_url=repository_url, |
| 401 | branch=branch, |
| 402 | program=program, |
| 403 | arguments=arguments, |
| 404 | env_base=env, |
| 405 | ) |
| 406 | |
| 407 | |
| 408 | @cli.command( |
nothing calls this directly
no test coverage detected