🔍 Code Extractor

Search Components

Full-Text: Fast keyword matching | Semantic: AI-powered understanding of intent (finds similar concepts)

Search Results for "threading"

Found 30 matching component(s)

  • class DocumentConverter

    A class that converts various document formats (Word, Excel, PowerPoint, OpenDocument, Visio) to PDF using LibreOffice's headless conversion capabilities, with support for parallel processing and directory structure preservation.

    File: /tf/active/vicechatdev/pdfconverter.py

    document-conversion pdf libreoffice batch-processing parallel-processing

  • function update_task_progress

    Thread-safe function that updates the progress and timestamp of an active task identified by task_id in a shared dictionary.

    File: /tf/active/vicechatdev/docchat/app.py

    task-management progress-tracking thread-safe concurrency locking

  • function complete_task

    Updates the status of a task to 'completed' in a thread-safe manner, storing the result and completion timestamp.

    File: /tf/active/vicechatdev/docchat/app.py

    task-management threading concurrency state-management thread-safe

  • function get_task_status_v1

    Thread-safe function that retrieves the current status of a task from a shared dictionary using a task identifier.

    File: /tf/active/vicechatdev/docchat/app.py

    threading concurrency task-management status-tracking thread-safe

  • function process_chat_background

    Processes chat requests asynchronously in a background thread, managing RAG engine interactions, progress updates, and session state for various query modes including basic, extensive, full_reading, and deep_reflection.

    File: /tf/active/vicechatdev/docchat/app.py

    background-processing async rag chat document-retrieval

  • function init_engines

    Initializes the RAG (Retrieval-Augmented Generation) engine and document indexer components, loads persisted sessions, and optionally starts background auto-indexing of documents.

    File: /tf/active/vicechatdev/docchat/app.py

    initialization RAG document-indexing background-processing threading

  • function api_chat

    Flask API endpoint that handles chat requests asynchronously, processing user queries through a RAG (Retrieval-Augmented Generation) engine with support for multiple modes, memory, web search, and custom configurations.

    File: /tf/active/vicechatdev/docchat/app.py

    flask api chat async rag

  • function process_full_reading_background

    Asynchronous background task processor that executes a full reading mode RAG (Retrieval-Augmented Generation) query, tracks progress, and stores results in session history.

    File: /tf/active/vicechatdev/docchat/app.py

    background-task async-processing rag full-reading-mode chat

  • function api_index_folder

    Flask API endpoint that initiates a background task to index documents in a specified folder, tracking progress and returning a task ID for status monitoring.

    File: /tf/active/vicechatdev/docchat/app.py

    flask api endpoint background-task document-indexing

  • function index_all_documents

    Flask route handler that initiates background indexing of all documents in the system, creating a task ID for tracking progress and returning immediately while indexing continues asynchronously.

    File: /tf/active/vicechatdev/docchat/blueprint.py

    flask api-endpoint background-task document-indexing async-processing

  • function run_with_timeout

    Executes a function with a specified timeout using threading, raising a TimeoutException if the function exceeds the time limit.

    File: /tf/active/vicechatdev/docchat/document_indexer.py

    timeout threading concurrency execution-control error-handling

  • class DocumentProcessor_v7

    Process different document types for indexing

    File: /tf/active/vicechatdev/docchat/document_indexer.py

    class documentprocessor

  • function complete_task_v1

    Thread-safe function that marks a task as completed by updating its status, storing the result, and recording the completion timestamp in a shared task dictionary.

    File: /tf/active/vicechatdev/vice_ai/app.py

    task-management threading concurrency state-management thread-safe

  • function cleanup_old_tasks_v1

    Removes tasks from the active_tasks dictionary that are older than 1 hour (3600 seconds) based on their creation timestamp, using thread-safe locking.

    File: /tf/active/vicechatdev/vice_ai/app.py

    cleanup task-management threading thread-safe memory-management

  • function get_user_documents

    Thread-safe function that retrieves all documents associated with a specific user email from a global document storage dictionary.

    File: /tf/active/vicechatdev/vice_ai/app.py

    document-management thread-safe user-data flask concurrency

  • function cleanup_old_documents

    Periodically removes documents and their associated files that are older than 2 hours from the uploaded_documents dictionary, cleaning up both file system storage and memory.

    File: /tf/active/vicechatdev/vice_ai/app.py

    cleanup maintenance file-management document-management scheduled-task

  • function api_chat_v1

    Handle chat API requests with support for long-running tasks

    File: /tf/active/vicechatdev/vice_ai/app.py

    function api_chat

  • function api_send_chat_message_v1

    Flask API endpoint that handles sending messages in a chat session, processes them through a RAG (Retrieval-Augmented Generation) engine with configurable LLM models, and returns AI-generated responses with references.

    File: /tf/active/vicechatdev/vice_ai/new_app.py

    chat api rag llm conversational-ai

  • function smartstat_run_analysis

    Flask API endpoint that initiates a SmartStat statistical analysis in a background thread, tracking progress and persisting results to a data section.

    File: /tf/active/vicechatdev/vice_ai/new_app.py

    flask api-endpoint background-processing statistical-analysis async

  • function run_permission_check_async

    Launches a background daemon thread to perform document permission checks without blocking the main application thread.

    File: /tf/active/vicechatdev/CDocs/controllers/permission_startup_check.py

    background-task threading permissions async-operation startup

  • function add_approval_comment_v1

    Adds a comment to an approval cycle with optional location information, page references, and reply threading. Validates user permissions, logs audit trails, and sends notifications to other approvers for issue-type comments.

    File: /tf/active/vicechatdev/CDocs/controllers/approval_controller_bis.py

    approval comment document-management collaboration audit-trail

  • function execute_enhanced_workflow_background

    Executes an enhanced SQL workflow in a background thread, retrieving data from a database, processing it through an AI-powered workflow, and automatically triggering statistical analysis on the results.

    File: /tf/active/vicechatdev/full_smartstat/app.py

    background-processing threading sql-workflow data-retrieval ai-powered

  • function enhanced_sql_workflow

    Flask route handler that initiates an enhanced SQL workflow with iterative optimization, executing data extraction and analysis in a background thread while providing real-time progress tracking.

    File: /tf/active/vicechatdev/full_smartstat/app.py

    flask api-endpoint sql-workflow async-processing background-thread

  • function analyze_data

    Flask route handler that initiates an asynchronous data analysis process based on user query, creating a background thread to perform the analysis and returning an analysis ID for progress tracking.

    File: /tf/active/vicechatdev/full_smartstat/app.py

    flask api-endpoint async threading data-analysis

  • function run_analysis_async

    Executes a data analysis workflow asynchronously with real-time progress tracking, including query interpretation, script generation, execution, and result finalization.

    File: /tf/active/vicechatdev/full_smartstat/app.py

    async data-analysis statistical-analysis progress-tracking llm-integration

  • class _state

    A global state management class that tracks and manages the state of running Panel applications, including server information, session data, busy status, and various application-level resources.

    File: /tf/active/vicechatdev/patches/state.py

    state-management global-state session-management server-management caching

  • function with_lock

    A decorator that wraps callback functions (both sync and async) to mark them for execution with a Bokeh document lock, allowing safe modification of Bokeh models.

    File: /tf/active/vicechatdev/patches/server.py

    decorator bokeh threading lock callback

  • function serve

    Serves one or more Panel objects on a single web server, allowing interactive dashboards and applications to be deployed locally or remotely with configurable networking and threading options.

    File: /tf/active/vicechatdev/patches/server.py

    server deployment web-server panel dashboard

  • class StoppableThread

    A custom thread class that extends threading.Thread with the ability to gracefully stop a Bokeh server running in the thread by stopping its IOLoop.

    File: /tf/active/vicechatdev/patches/server.py

    threading bokeh server tornado ioloop

  • class periodic

    A threading class that executes a callback function periodically at specified intervals, with optional count limits and timeout controls.

    File: /tf/active/vicechatdev/patches/util.py

    threading periodic-execution scheduling timer callback

Search Examples