Function replay

python/pathway/cli.py:484–523

(
    threads,
    processes,
    first_port,
    addresses,
    process_id,
    record_path,
    mode,
    continue_after_replay,
    repository_url,
    branch,
    program,
    arguments,
)

@click.argument("program")
@click.argument("arguments", nargs=-1)
def replay(
    threads,
    processes,
    first_port,
    addresses,
    process_id,
    record_path,
    mode,
    continue_after_replay,
    repository_url,
    branch,
    program,
    arguments,
):
    processes, process_id = validate_and_resolve_spawn_args(
        threads=threads,
        processes=processes,
        first_port=first_port,
        addresses=addresses,
        process_id=process_id,
    )
    env = os.environ.copy()
    env["PATHWAY_REPLAY_STORAGE"] = record_path
    env["PATHWAY_SNAPSHOT_ACCESS"] = "replay"
    env["PATHWAY_PERSISTENCE_MODE"] = mode
    env["PATHWAY_REPLAY_MODE"] = mode
    if continue_after_replay:
        env["PATHWAY_CONTINUE_AFTER_REPLAY"] = "true"
    spawn_program(
        threads=threads,
        processes=processes,
        first_port=first_port,
        addresses=addresses,
        process_id=process_id,
        repository_url=repository_url,
        branch=branch,
        program=program,
        arguments=arguments,
        env_base=env,
    )


@cli.command()