Skip to content

Commit 01c4313

Browse files
author
Andrei Bratu
committed
going through tests
1 parent f365615 commit 01c4313

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/humanloop/otel/exporter.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -207,12 +207,12 @@ def _export_span_dispatch(self, span: ReadableSpan) -> None:
207207

208208
if file_type == "prompt":
209209
self._export_prompt_span(span=span)
210-
if file_type == "tool":
210+
elif file_type == "tool":
211211
self._export_tool_span(span=span)
212-
if file_type == "flow":
212+
elif file_type == "flow":
213213
self._export_flow_span(span=span)
214214
else:
215-
raise NotImplementedError(f"Unknown span type: {hl_file}")
215+
raise NotImplementedError(f"Unknown span type: {file_type}")
216216

217217
def _export_prompt_span(self, span: ReadableSpan) -> None:
218218
file_object: dict[str, Any] = read_from_opentelemetry_span(

src/humanloop/otel/processor/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,8 @@ def _get_waiting_parent(self, span: ReadableSpan) -> Optional[ReadableSpan]:
126126

127127
def _add_dependency_to_await(self, span: ReadableSpan):
128128
# We know this span has a parent, need to satisfy the type checker
129-
parent_span_id = span.parent.span_id # type: ignore
130129
if self._is_dependency(span):
130+
parent_span_id = span.parent.span_id # type: ignore
131131
self._dependencies[parent_span_id].append(DependantSpan(span=span, finished=False))
132132

133133
def _track_flow_traces(self, span: ReadableSpan):

0 commit comments

Comments
 (0)