Override user configuation with CLI options. Allow overriding with None

Signed-off-by: Krzysztof Boronski <kboronski@antmicro.com>
This commit is contained in:
Krzysztof Boronski 2022-08-08 10:47:53 -05:00 committed by Unai Martinez-Corral
parent 77d5eaeb26
commit 64022f1e77
4 changed files with 68 additions and 8 deletions

View File

@ -116,6 +116,10 @@ def _parse_depval(depvalstr: str):
return d return d
def _null_generator():
return (item for item in [])
def _unescaped_matches(regexp: str, s: str, escape_chr="\\"): def _unescaped_matches(regexp: str, s: str, escape_chr="\\"):
""" """
Find all occurences of a pattern in a string that contains escape sequences. Find all occurences of a pattern in a string that contains escape sequences.
@ -128,17 +132,23 @@ def _unescaped_matches(regexp: str, s: str, escape_chr="\\"):
# unescaped characters, but to map the results back to the string containing the # unescaped characters, but to map the results back to the string containing the
# escape sequences, we need to track the offsets by which the characters were # escape sequences, we need to track the offsets by which the characters were
# shifted. # shifted.
# TODO: This doesn't handle self-escape case
offsets = [] offsets = []
offset = 0 offset = 0
for sl in s.split(escape_chr): for sl in s.split(escape_chr):
if len(sl) <= 1: noescape = sl[(1 if offset != 0 else 0) :] if len(sl) > 1 else ""
continue
noescape = sl[(1 if offset != 0 else 0) :]
for _ in noescape: for _ in noescape:
offsets.append(offset) offsets.append(offset)
offset += 2 offset += 2
noescapes += noescape noescapes += noescape
if len(offsets) == 0:
return _null_generator()
last_offset = offsets[-1]
offsets.append(last_offset)
iter = re_finditer(regexp, noescapes) iter = re_finditer(regexp, noescapes)
for m in iter: for m in iter:
@ -188,7 +198,7 @@ def _parse_cli_value(s: str):
""" """
if len(s) == 0: if len(s) == 0:
return "" return None
# List # List
if s[0] == "[": if s[0] == "[":

View File

@ -44,6 +44,7 @@ from f4pga.flows.flow_config import (
FlowConfig, FlowConfig,
FlowDefinition, FlowDefinition,
open_project_flow_cfg, open_project_flow_cfg,
override_prj_flow_cfg_by_cli,
verify_platform_name, verify_platform_name,
) )
from f4pga.flows.flow import Flow from f4pga.flows.flow import Flow
@ -219,13 +220,14 @@ def cmd_build(args: Namespace):
project_flow_cfg = open_project_flow_config(args.flow) project_flow_cfg = open_project_flow_config(args.flow)
elif part_name is not None: elif part_name is not None:
project_flow_cfg = ProjectFlowConfig(".temp.flow.json") project_flow_cfg = ProjectFlowConfig(".temp.flow.json")
project_flow_cfg.flow_cfg = get_cli_flow_config(args, part_name)
if part_name is None and project_flow_cfg is not None: if part_name is None and project_flow_cfg is not None:
part_name = project_flow_cfg.get_default_part() part_name = project_flow_cfg.get_default_part()
if project_flow_cfg is None: if (project_flow_cfg is None) and part_name is None:
fatal(-1, "No configuration was provided. Use `--flow`, and/or " "`--part` to configure flow.") fatal(-1, "No configuration was provided. Use `--flow`, and/or " "`--part` to configure flow.")
override_prj_flow_cfg_by_cli(project_flow_cfg, get_cli_flow_config(args, part_name))
flow_cfg = make_flow_config(project_flow_cfg, part_name) flow_cfg = make_flow_config(project_flow_cfg, part_name)
if args.info: if args.info:

View File

@ -70,7 +70,7 @@ class Flow:
self.dep_paths = { self.dep_paths = {
n: p n: p
for n, p in cfg.get_dependency_overrides().items() for n, p in cfg.get_dependency_overrides().items()
if p_req_exists(p) # and not p_dep_differ(p, f4cache) if (p is not None) and p_req_exists(p) # and not p_dep_differ(p, f4cache)
} }
if f4cache is not None: if f4cache is not None:
for dep in self.dep_paths.values(): for dep in self.dep_paths.values():

View File

@ -132,6 +132,54 @@ class ProjectFlowConfig:
return platform_ovds return platform_ovds
def override_prj_flow_cfg_by_cli(cfg: ProjectFlowConfig, cli_d: "dict[str, dict[str, dict]]"):
for part_name, part_cfg in cli_d.items():
print(f"OVERRIDING CONFIG FOR {part_name}")
p_cfg = cfg.flow_cfg.get(part_name)
if p_cfg is None:
p_cfg = {}
cfg.flow_cfg[part_name] = p_cfg
cli_p_values = part_cfg.get("values")
cli_p_dependencies = part_cfg.get("dependencies")
p_values = p_cfg.get("values")
p_dependencies = p_cfg.get("dependencies")
if cli_p_values is not None:
if p_values is None:
p_values = {}
part_cfg["values"] = p_values
p_values.update(cli_p_values)
if cli_p_dependencies is not None:
if p_dependencies is None:
p_dependencies = {}
part_cfg["dependencies"] = p_dependencies
p_dependencies.update(cli_p_dependencies)
for stage_name, cli_stage_cfg in part_cfg.items():
if _is_kword(stage_name):
continue
stage_cfg = part_cfg.get(stage_name)
if stage_cfg is None:
stage_cfg = {}
part_cfg[stage_name] = stage_cfg
stage_values = stage_cfg.get("values")
stage_dependencies = stage_cfg.get("dependencies")
cli_stage_values = cli_stage_cfg.get("values")
cli_stage_dependencies = cli_stage_cfg.get("dependencies")
if cli_stage_values is not None:
if stage_values is None:
stage_values = {}
stage_cfg["values"] = stage_values
stage_values.update(cli_stage_values)
if cli_stage_dependencies is not None:
if stage_dependencies is None:
stage_dependencies = {}
stage_cfg["dependencies"] = stage_dependencies
stage_dependencies.update(cli_stage_dependencies)
class FlowConfig: class FlowConfig:
part: str part: str
r_env: ResolutionEnv r_env: ResolutionEnv
@ -144,7 +192,7 @@ class FlowConfig:
self.stages = platform_def.stages self.stages = platform_def.stages
self.part = part self.part = part
self.dependencies_explicit = deep(lambda p: str(Path(p).resolve()))( self.dependencies_explicit = deep(lambda p: str(Path(p).resolve()), allow_none=True)(
self.r_env.resolve(project_config.get_dependencies_raw(part)) self.r_env.resolve(project_config.get_dependencies_raw(part))
) )