Function init_files

app/api/agentops/exporter/processor.py:530–547

Initialize files needed for the exporter.

()

def init_files():
    """Initialize files needed for the exporter."""
    global _last_session_file, LAST_SESSION_ID

    # Initialize dropped records file
    if not os.path.exists(DROPPED_RECORDS_FILENAME):
        with open(DROPPED_RECORDS_FILENAME, 'w') as f:
            f.write("table,id,exception\n")

    # Initialize last session ID file
    if not os.path.exists(LAST_SESSION_ID_FILENAME):
        from pathlib import Path

        Path(LAST_SESSION_ID_FILENAME).touch()

    # Open the last session ID file
    _last_session_file = open(LAST_SESSION_ID_FILENAME, 'r+')
    LAST_SESSION_ID = _last_session_file.read().strip()


async def main() -> None: