fix: add trace_name parameter to method call
This commit is contained in:
parent
78fbbaed1f
commit
da5eec8fc7
1 changed files with 4 additions and 2 deletions
|
|
@ -122,7 +122,8 @@ class Component(CustomComponent):
|
||||||
f"{self.display_name} ({self.vertex.id})", self.trace_type, inputs, metadata
|
f"{self.display_name} ({self.vertex.id})", self.trace_type, inputs, metadata
|
||||||
):
|
):
|
||||||
_results, _artifacts = await self._build_results()
|
_results, _artifacts = await self._build_results()
|
||||||
self._tracing_service.set_outputs(_results)
|
trace_name = self._tracing_service.run_name
|
||||||
|
self._tracing_service.set_outputs(trace_name, _results)
|
||||||
|
|
||||||
return _results, _artifacts
|
return _results, _artifacts
|
||||||
|
|
||||||
|
|
@ -181,7 +182,8 @@ class Component(CustomComponent):
|
||||||
self._artifacts = _artifacts
|
self._artifacts = _artifacts
|
||||||
self._results = _results
|
self._results = _results
|
||||||
if self._tracing_service:
|
if self._tracing_service:
|
||||||
self._tracing_service.set_outputs(_results)
|
trace_name = self._tracing_service.run_name
|
||||||
|
self._tracing_service.set_outputs(trace_name, _results)
|
||||||
return _results, _artifacts
|
return _results, _artifacts
|
||||||
|
|
||||||
def custom_repr(self):
|
def custom_repr(self):
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue