clean

Author: axiomofjoy

src/phoenix/server/api/mutations/span_annotations_mutations.py

@@ -88,12 +88,8 @@ async def create_span_annotations(
                 q = select(models.SpanAnnotation).where(
                     models.SpanAnnotation.span_rowid == span_rowid,
                     models.SpanAnnotation.name == annotation_input.name,
+                    models.SpanAnnotation.identifier == resolved_identifier,
                 )
-                if resolved_identifier is None:
-                    q = q.where(models.SpanAnnotation.identifier.is_(None))
-                else:
-                    q = q.where(models.SpanAnnotation.identifier == resolved_identifier)
-
                 existing_annotation = await session.scalar(q)
 
                 if existing_annotation:

src/phoenix/server/api/mutations/trace_annotations_mutations.py

@@ -82,12 +82,8 @@ async def create_trace_annotations(
                 q = select(models.TraceAnnotation).where(
                     models.TraceAnnotation.trace_rowid == trace_rowid,
                     models.TraceAnnotation.name == annotation_input.name,
+                    models.TraceAnnotation.identifier == resolved_identifier,
                 )
-                if resolved_identifier is None:
-                    q = q.where(models.TraceAnnotation.identifier.is_(None))
-                else:
-                    q = q.where(models.TraceAnnotation.identifier == resolved_identifier)
-
                 existing_annotation = await session.scalar(q)
 
                 if existing_annotation: