We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a6cef12 commit 767bc29Copy full SHA for 767bc29
torchx/specs/api.py
@@ -63,6 +63,9 @@
63
# (most recent call first):
64
_EMBEDDED_ERROR_MESSAGE_RE: Pattern[str] = re.compile(r"(?P<msg>.+)\nException.*")
65
66
+YELLOW_BOLD = "\033[1;33m"
67
+RESET = "\033[0m"
68
+
69
70
# ========================================
71
# ==== Distributed AppDef API =======
@@ -937,6 +940,10 @@ def _cast_to_type(value: str, opt_type: Type[CfgVal]) -> CfgVal:
937
940
runopt_ = self.get(key)
938
941
if runopt_:
939
942
cfg[key] = _cast_to_type(val, runopt_.opt_type)
943
+ else:
944
+ logger.warning(
945
+ f"{YELLOW_BOLD}Unknown run option passed to scheduler: {key}={val}{RESET}"
946
+ )
947
return cfg
948
949
def cfg_from_json_repr(self, json_repr: str) -> Dict[str, CfgVal]:
0 commit comments