Format a task_finish data event for structured CLI display (ASK_DATA mode). Handles common field layouts returned by the Data Agent: - stat

Format ask_sql confirmation prompt.

Handle chat_finish events — completions and user confirmations.

Handle chat_start events — mark the beginning of a new turn.

Flush accumulators when content lifecycle ends.

Set content_category and initialise accumulators.

Second-level dispatch by category for data events.

Fallback for unrecognised data categories — extract title/step. Only shown in detail mode.

Handle data/jsx_report events. Shown in all modes.

Handle data/mission_report events. Shown in all modes.

Handle data/task_finish — structured query result.

Accumulate delta content based on category.

Handle SSE_FAILURE events.

Handle status_change events. Only visible in detail mode.

Convert TeaException to appropriate custom exception. Args: e: The TeaException to handle. Raises: Authentic

Initialize DMS Enterprise client using default credential chain.

Initialize async DMS Enterprise client using default credential chain.

Initialize the underlying SDK client based on authentication type.

Check if a process with the given PID is still running.

List DMS instances using MCP tool.

List tables in a database.

Map image MIME subtype to file extension.

Build an Alibaba Cloud ClientToken that is stable across retries.

Search databases by schema name.

Write the current process PID to the lock file.

Add DMS database tables to Data Agent Data Center. This method imports DMS database tables into Data Agent's Data Center using the Ad

Build command-line argument parser.

Convert camelCase string to PascalCase.

Check if a worker is already running for this session. Returns the PID of the running worker, or None if no worker is active. Stale lock file

Recursively convert all dictionary keys to camelCase. Args: obj: Input object (dict, list, or primitive) api_action: API action n

Delete an uploaded file. Args: file_id: The file ID to delete. session_id: Optional session ID used to verify the fil

Get detailed information about a custom agent. Args: custom_agent_id: The custom agent ID. workspace_id: Optional wor

Execute a batch of queries with streaming output. Args: message_handler: Message handler instance session: Session object

Execute a single query with streaming output. Args: message_handler: Message handler instance session: Session object que

Get the active OpenClaw / Clawdbot session ID.

Get session and agent IDs from environment variables in worker process.

Initialize common Data Agent components.

Check if a session is still active and usable. Args: session_id: The session ID to check. Returns: True if s

Check if a session is still active asynchronously. Args: session_id: The session ID to check. Returns: True

List custom agents, default to RELEASED status only. Args: workspace_id: Optional workspace ID to filter agents. sear

List databases registered in DMS Data Center (legacy file-based). Args: search_key: Optional keyword to filter by database or ins

List files associated with a session asynchronously. Args: session_id: The session ID. Returns: List of File

Search for database instances in DMS. Args: search_key: Optional search key (e.g., instance host, alias). db_

List tables for a database via ListTagMetaAsset. Falls back to list_file_tables in API_KEY mode (not supported without extra params).

List tables in a database. Args: database_id: Database ID to search tables in (required). search_name: Table

List Data Agent workspaces under the current account. Args: workspace_type: Workspace type filter ("MY" or "ALL"). wo

Convert PascalCase string to camelCase.

Process the temporary output file and create log format only (progress.jsonl disabled).

Remove the lock file if it belongs to the current process.

Search databases by schema name in DMS. Args: search_key: Schema name search keyword (required). page_number:

Stream chat content asynchronously. Automatically reconnects from the last checkpoint on SSL/connection errors, enabling resilience d

Send query and stream raw SSE events. Args: session: Active session to use. query: Natural language query.

Validate configuration values. Raises: ConfigurationError: If required configuration is missing or invalid.

Run the verification. Returns process exit code. Interpretation of responses (based on confirmed OpenAPI spec): - body has Route/data objec

Wait for session to reach RUNNING state asynchronously. Args: session_id: The session ID. agent_id: The agent ID (opt

Write structured data to the JSONL file. Args: data: Dictionary containing structured log data.

Write text to the plain log file (e.g., progress.log or process.log). Args: text: Text to write to the plain text log.

Write the spawned worker PID to the lock file (called by parent).

Enter context manager, opening log file.

Exit context manager, closing log file.

Initialize the log handler. Args: session_dir: Directory for the session where logs will be stored. log_prefix: Prefi

Initialize the Data Agent client. Args: config: Configuration for the client.

Initialize the async Data Agent client. Args: config: Configuration for the client.

Initialize file manager. Args: client: DataAgentClient instance for API calls.

Initialize async file manager. Args: client: AsyncDataAgentClient instance for API calls.

Initialize SSE client. Args: config: Data Agent configuration.

Initialize async SSE client. Args: config: Data Agent configuration.

Initialize DMS MCP tools. Args: config: Data Agent configuration containing credentials.

Initialize async DMS MCP tools. Args: config: Data Agent configuration.

Initialize session manager. Args: client: DataAgentClient instance for API calls.

Initialize async session manager. Args: client: AsyncDataAgentClient instance for API calls.

Initialize message handler. Args: client: DataAgentClient instance for API calls.

Initialize async message handler. Args: client: AsyncDataAgentClient instance for API calls.

Generate endpoint if not provided and validate config.

String representation (hides secrets).

Parse and format a data event's content for CLI display. Returns a formatted string to print, or None to suppress the event.

Calculate HMAC-SHA256.

Check if an SSE event requires user confirmation.

Natural language query database (NL2SQL + execute SQL). Note: This is a placeholder implementation. The actual askDatabase fu

Remove stale sessions from cache. Args: max_age_minutes: Maximum session age in minutes. Returns: Number of

Handle agent subcommand.

Connect to an existing session for continuing analysis or confirming plan.