Function write_dropped_record

app/api/agentops/exporter/processor.py:72–76

Make a note of a record that was dropped during processing.

(table: str, id: Any, exception: Exception)

def write_dropped_record(table: str, id: Any, exception: Exception) -> None:
    """Make a note of a record that was dropped during processing."""
    with open(DROPPED_RECORDS_FILENAME, 'a') as f:
        msg = str(exception).replace('"', "'").replace("\n", " ~ ")
        f.write(f"{table},{str(id)},\"{msg}\"\n")


def write_last_session_id(session_id: Any) -> None: