fix logs
This commit is contained in:
parent
1ba029a8b0
commit
09c21fca06
3 changed files with 4 additions and 3 deletions
|
|
@ -187,7 +187,8 @@ async def build_vertex(
|
||||||
logger.exception(f"Error building vertex: {exc}")
|
logger.exception(f"Error building vertex: {exc}")
|
||||||
params = format_exception_message(exc)
|
params = format_exception_message(exc)
|
||||||
valid = False
|
valid = False
|
||||||
logs = {vertex.outputs[0]["name"]: [Log(message=params, type="error")]}
|
output_label = vertex.outputs[0]["name"] if vertex.outputs else "output"
|
||||||
|
logs = {output_label: [Log(message=params, type="error")]}
|
||||||
result_data_response = ResultDataResponse(results={})
|
result_data_response = ResultDataResponse(results={})
|
||||||
artifacts = {}
|
artifacts = {}
|
||||||
# If there's an error building the vertex
|
# If there's an error building the vertex
|
||||||
|
|
|
||||||
|
|
@ -245,7 +245,7 @@ class VerticesOrderResponse(BaseModel):
|
||||||
|
|
||||||
class ResultDataResponse(BaseModel):
|
class ResultDataResponse(BaseModel):
|
||||||
results: Optional[Any] = Field(default_factory=dict)
|
results: Optional[Any] = Field(default_factory=dict)
|
||||||
logs: dict[str, Log] = Field(default_factory=dict)
|
logs: dict[str, List[Log]] = Field(default_factory=dict)
|
||||||
message: Optional[Any] = Field(default_factory=dict)
|
message: Optional[Any] = Field(default_factory=dict)
|
||||||
artifacts: Optional[Any] = Field(default_factory=dict)
|
artifacts: Optional[Any] = Field(default_factory=dict)
|
||||||
timedelta: Optional[float] = None
|
timedelta: Optional[float] = None
|
||||||
|
|
|
||||||
|
|
@ -29,7 +29,7 @@ def build_logs_from_artifacts(artifacts: dict) -> dict:
|
||||||
elif _type:
|
elif _type:
|
||||||
log = Log(message=message, type=_type)
|
log = Log(message=message, type=_type)
|
||||||
|
|
||||||
logs[key] = log
|
logs[key] = [log]
|
||||||
return logs
|
return logs
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue