2024-07-29 18:29:54 -04:00
|
|
|
#!/usr/bin/env python3
|
|
|
|
|
|
|
|
from flupdt.flake_show import get_derivations
|
|
|
|
from flupdt.cli import parse_inputs
|
2024-08-02 09:13:06 -04:00
|
|
|
from flupdt.flake_eval import evaluate_output
|
2025-03-02 00:41:33 -05:00
|
|
|
from flupdt.common import configure_logger
|
2024-08-02 09:13:06 -04:00
|
|
|
import logging
|
2024-08-03 00:21:44 -04:00
|
|
|
|
2024-07-29 18:29:54 -04:00
|
|
|
|
2025-03-01 23:29:01 -05:00
|
|
|
def main() -> None:
|
|
|
|
"""Sets up logging, parses args, and runs evaluation routine.
|
|
|
|
|
|
|
|
:returns: None
|
|
|
|
|
|
|
|
"""
|
2025-03-02 00:41:33 -05:00
|
|
|
configure_logger("INFO")
|
2024-07-29 18:29:54 -04:00
|
|
|
args = parse_inputs()
|
2024-08-02 09:13:06 -04:00
|
|
|
flake_path = args.flake_path
|
2025-03-01 23:29:01 -05:00
|
|
|
derivations, hydra_jobs = rd.partition(
|
2024-08-04 11:24:38 -04:00
|
|
|
lambda s: s.startswith("hydraJobs"), get_derivations(flake_path)
|
|
|
|
)
|
2024-08-02 09:13:06 -04:00
|
|
|
logging.info(f"derivations: {list(derivations)}")
|
|
|
|
for d in derivations:
|
|
|
|
evaluate_output(flake_path, d)
|
2024-07-29 18:29:54 -04:00
|
|
|
|
2024-08-04 11:24:38 -04:00
|
|
|
if not args.keep_hydra:
|
|
|
|
logging.info("--keep-hydra flag is not specified, removing Hydra jobs")
|
|
|
|
else:
|
2025-03-01 23:29:01 -05:00
|
|
|
logging.info(f"hydraJobs: {list(hydra_jobs)}")
|
|
|
|
for d in hydra_jobs:
|
2024-08-04 11:24:38 -04:00
|
|
|
evaluate_output(flake_path, d)
|
|
|
|
|
2024-07-29 18:29:54 -04:00
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
|
main()
|