Search - Code Extractor

function create_task

Creates and registers a new background task in a thread-safe manner by initializing its metadata in a shared dictionary with status tracking, progress information, and timestamps.

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

task-management background-tasks thread-safe concurrency task-tracking

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 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_task_status

Flask API endpoint that retrieves and returns the status of asynchronous tasks (chat or indexing operations) by task ID.

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

api flask rest-endpoint task-status async-polling

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 api_index_progress

Flask API endpoint that retrieves the current progress status of an asynchronous indexing task by its task ID.

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

flask api rest-endpoint progress-tracking async-task

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 get_task_status

Flask API endpoint that retrieves the current status of a background task by its task ID from an in-memory active_tasks dictionary.

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

flask api rest-endpoint task-status background-task

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

function create_task_v1

Creates and registers a new background task entry in a thread-safe manner, initializing its status, progress, user information, and timestamps.

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

task-management background-tasks thread-safe concurrency task-tracking

function fail_task

Marks a task as failed by updating its status, recording the error message, and setting the completion timestamp in a thread-safe manner.

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

task-management error-handling thread-safe concurrency state-management

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_task_status_v1

Flask API endpoint that retrieves and returns the status of a background task, with user authorization checks.

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

api flask background-tasks task-status authentication

function text_chat_get_progress

Flask API endpoint that retrieves the progress status of an asynchronous text chat job, particularly for multi-cycle web search operations.

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

flask api progress-tracking async polling

function data_section_analysis_chat

Async Flask route handler that processes chat messages for data section analysis, managing conversation history and integrating with a statistical analysis service.

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

flask api-endpoint async chat data-analysis

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 smartstat_get_progress

Flask API endpoint that retrieves the progress status of a SmartStat analysis job by job_id, returning progress data and completed results if available.

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

flask api rest-endpoint progress-tracking async-jobs

function analysis_chat

Flask route handler that processes chat messages for data analysis sessions, verifying user authentication and session ownership before delegating to the data analysis service.

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

flask api-endpoint data-analysis chat async

class DataAnalysisService

Service class for managing data analysis operations within document sections, integrating with SmartStat components for statistical analysis, dataset processing, and visualization generation.

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

data-analysis statistical-analysis session-management dataset-processing visualization

function initialize_system

Initializes the CDocs document management system by setting up database connections, FileCloud integration, document sharing validation, and API routes.

File: /tf/active/vicechatdev/CDocs/initialize_system.py

initialization system-startup database filecloud api-routes

class ControlledDocumentApp

Main application class for the Controlled Document Management System. This class initializes all components and provides the main Panel interface for the application. It is designed to be served via `panel serve` command and integrates with the existing datacapture application.

File: /tf/active/vicechatdev/CDocs/main.py

class controlleddocumentapp

class SSOCallbackHandler

A Tornado RequestHandler that processes OAuth 2.0 callbacks from Azure AD, exchanges authorization codes for access tokens, validates user identity, and sets authentication cookies for SSO integration.

File: /tf/active/vicechatdev/CDocs/sso_plugin.py

oauth azure-ad sso authentication tornado

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 async_action

A decorator function that marks another function as asynchronous by adding an 'is_async' attribute, while preserving the original function's metadata.

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

decorator async metadata marker action

function _continue_to_analysis

Continues statistical analysis workflow after data retrieval by configuring analysis parameters, executing statistical analysis via StatisticalAnalysisService, and updating workflow progress status.

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

statistical-analysis workflow-continuation async-processing session-management data-analysis

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

function get_analysis_progress

Flask route handler that retrieves the progress status of a running analysis task and performs cleanup of completed/failed analyses after a timeout period.

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

flask api-endpoint progress-tracking async-monitoring cleanup

function main_v8

Asynchronous main entry point function that initializes and runs an email forwarding SMTP server with logging, configuration validation, and graceful shutdown handling.

File: /tf/active/vicechatdev/email-forwarder/src/main.py

async smtp email server entry-point

class EmailForwardingHandler

SMTP message handler class that processes incoming email messages and forwards them using an EmailHandler instance while tracking server statistics.

File: /tf/active/vicechatdev/email-forwarder/src/forwarder/smtp_server.py

smtp email async aiosmtpd email-forwarding

class SMTPServer

SMTPServer is a class that manages an SMTP server for receiving emails, handling their forwarding, and providing server statistics.

File: /tf/active/vicechatdev/email-forwarder/src/forwarder/smtp_server.py

smtp email server async networking

function run_smtp_server

Initializes and runs an asynchronous SMTP server using a new event loop, with proper error handling and graceful shutdown.

File: /tf/active/vicechatdev/email-forwarder/src/forwarder/smtp_server.py

smtp email server async asyncio

function async_execute

Wraps and schedules async function execution in the appropriate event loop context, ensuring proper lock propagation and document context management for Bokeh/Panel applications.

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

async event-loop bokeh panel tornado

class Application

A custom Bokeh Application subclass that extends BkApplication to integrate with Panel's state management system, handling session creation callbacks and document initialization with templates.

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

bokeh server application session-management document-initialization

class DocHandler

DocHandler is a Tornado request handler that serves HTML pages for Bokeh sessions, combining session management with document rendering capabilities.

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

tornado bokeh web-handler session-management document-rendering

class AutoloadJsHandler

A custom Tornado request handler that generates and serves the Bokeh autoload JavaScript chunk for embedding Bokeh applications in web pages.

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

tornado bokeh web-handler javascript autoload

class RootHandler

A custom Tornado request handler that extends Bokeh's RootHandler to handle root URL requests with authentication and conditional redirection based on index file extensions.

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

tornado bokeh web-handler authentication routing

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

Search Components

Search Results for "async"

function create_task

function update_task_progress

function complete_task

function get_task_status_v1

function process_chat_background

function api_chat

function process_full_reading_background

function api_task_status

function api_index_folder

function api_index_progress

function index_all_documents

function get_task_status

function run_with_timeout

function create_task_v1

function fail_task

function api_chat_v1

function api_task_status_v1

function text_chat_get_progress

function data_section_analysis_chat

function smartstat_run_analysis

function smartstat_get_progress

function analysis_chat

class DataAnalysisService

function initialize_system

class ControlledDocumentApp

class SSOCallbackHandler

function run_permission_check_async

function async_action

function _continue_to_analysis

function execute_enhanced_workflow_background

function enhanced_sql_workflow

function analyze_data

function run_analysis_async

function get_analysis_progress

function main_v8

class EmailForwardingHandler

class SMTPServer

function run_smtp_server

function async_execute

class Application

class DocHandler

class AutoloadJsHandler

class RootHandler

function with_lock

Search Examples