hub / github.com/aliyun/data-agent-skill / run_worker_with_handler

Function run_worker_with_handler

scripts/cli/streaming_utils.py:123–206 · view source on GitHub ↗

Generic worker execution with common error handling and session management. Args: args: Command line arguments data_source: Optional data source for queries query_execution_func: Function to execute queries, receives (message_handler, session, args)

(
    args,
    data_source: Optional[DataSource] = None,
    query_execution_func=None
)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 3

cmd_fileFunction · 0.90

cmd_dbFunction · 0.90

cmd_attachFunction · 0.90

Calls 10

get_worker_session_detailsFunction · 0.90

acquire_worker_lockFunction · 0.90

initialize_componentsFunction · 0.90

handle_worker_completionFunction · 0.90

release_worker_lockFunction · 0.90

close_structured_loggingFunction · 0.90

execute_single_queryFunction · 0.85

execute_query_batchFunction · 0.85

closeMethod · 0.80

create_or_reuseMethod · 0.45

Tested by

no test coverage detected