Function submit

benchmarks/src/submit/submit.py:77–114

(
    identifiers: List[BenchmarkIdentifier],
    workdir: Path,
    options: PBSSubmitOptions,
    database_path: Optional[Path] = None,
    resubmit=False,
)

def submit(
    identifiers: List[BenchmarkIdentifier],
    workdir: Path,
    options: PBSSubmitOptions,
    database_path: Optional[Path] = None,
    resubmit=False,
) -> str:
    workdir = Path(workdir).absolute()
    workdir.mkdir(parents=True, exist_ok=True)

    identifiers_path = workdir / "benchmarks.json"
    serialize_identifiers(identifiers, identifiers_path)

    submit_options_path = workdir / "submit-options.json"
    serialize_submit_options(options, submit_options_path)

    header = create_submit_script_header(workdir, options)
    script_body = create_submit_script_body(
        header,
        options,
        identifiers_path,
        submit_options_path,
        workdir,
        database_path=database_path,
        resubmit=resubmit,
    )

    script_path = workdir / "submit.sh"
    with open(script_path, "w") as f:
        f.write(script_body)

    logging.info(f"Submitting PBS script: {script_path}")
    logging.debug(f"Script body: {script_body}")
    result = subprocess.run(["qsub", script_path], stdout=subprocess.PIPE, check=True)
    job_id = result.stdout.decode().strip()
    logging.info(f"Job id: {job_id}")

    return job_id


def watch_pbs(job_id: str):