fix: checker bug_fix (#840)
This commit is contained in:
parent
1c23a2e24a
commit
810e25c487
|
|
@ -1329,10 +1329,11 @@ async def _handle_create_observations_impl(
|
|||
# normalize so provenance links reference real document IDs.
|
||||
source_ids = obs.get("source_ids")
|
||||
if isinstance(source_ids, list):
|
||||
obs["source_ids"] = [
|
||||
_normalize_observation_id(s) for s in source_ids if isinstance(s, str)
|
||||
]
|
||||
|
||||
normalized_source_ids: list[str] = []
|
||||
for source_id in cast(list[Any], source_ids):
|
||||
if isinstance(source_id, str):
|
||||
normalized_source_ids.append(_normalize_observation_id(source_id))
|
||||
obs["source_ids"] = normalized_source_ids
|
||||
# Validate observations individually so valid ones are still processed
|
||||
observations: list[schemas.ObservationInput] = []
|
||||
validation_failures: list[ObservationFailure] = []
|
||||
|
|
|
|||
Loading…
Reference in New Issue