Function main

app/api/agentops/exporter/processor.py:550–569

Main entry point for the exporter

()

async def main() -> None:
    """Main entry point for the exporter"""
    # Initialize files
    init_files()

    try:
        row_count = await count_session_rows()
        total_pages = row_count // BATCH_ROW_COUNT
        print(f"Total pages: {total_pages}".center(80, "="))

        for page_number in range(0, total_pages):
            offset, limit = page_number * BATCH_ROW_COUNT, BATCH_ROW_COUNT
            await process_page(offset, limit)
            print(f"Processed page {page_number}".center(80, "="))
            if MAX_PAGES is not None and MAX_PAGES >= page_number:
                break
    finally:
        if _last_session_file:
            _last_session_file.close()
        await close_supabase_pool()


if __name__ == "__main__":