crash the fking thing
This commit is contained in:
@@ -158,11 +158,12 @@ class ServerPipelineManager:
|
|||||||
if hasattr(loaded_cfg, "setup"):
|
if hasattr(loaded_cfg, "setup"):
|
||||||
cfg = loaded_cfg
|
cfg = loaded_cfg
|
||||||
else:
|
else:
|
||||||
logger.warning(
|
raise ValueError(
|
||||||
f"config_file for pipeline `{pipeline_id}` did not deserialize to config object; "
|
"config_file for pipeline "
|
||||||
"falling back to default config and applying pipeline-level overrides."
|
f"`{pipeline_id}` did not deserialize to a config object. "
|
||||||
|
"Rebuild the pipeline via /v1/pipelines to regenerate a "
|
||||||
|
"valid serialized PipelineConfig file."
|
||||||
)
|
)
|
||||||
cfg = copy.deepcopy(self.default_config)
|
|
||||||
else:
|
else:
|
||||||
cfg = copy.deepcopy(self.default_config)
|
cfg = copy.deepcopy(self.default_config)
|
||||||
if not isinstance(overrides, dict):
|
if not isinstance(overrides, dict):
|
||||||
|
|||||||
Reference in New Issue
Block a user