com/alibaba/qwen/code/managedagent/persistence/AgentEventJournal.java|SELECT last_sequence FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X'' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentEventJournal.java|UPDATE ma_event_stream SET last_sequence = ?, gmt_modified = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentEventJournal.java|UPDATE ma_session SET harness_event_epoch = ?, harness_last_event_id = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentEventJournal.java|WHERE ma_session.tenant_id = ? AND ma_session.session_kind = 'PUBLIC' AND ma_session.session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_operation.tenant_id AND private_scope.session_id = ma_operation.session_id AND private_scope.is_csi_guard = FALSE) ORDER BY claim_until LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|AND state = 'RECOVERY_BLOCKED' AND available_at <= ? AND delivery_state = 'BLOCKED' AND EXISTS (SELECT 1 FROM ma_session s WHERE s.tenant_id = ma_operation.tenant_id AND s.session_id = ma_operation.session_id AND s.is_csi_guard = FALSE) ORDER BY available_at LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|SELECT (SELECT content_digest FROM ma_session_journal_tx WHERE tenant_id = ? AND session_id = ? AND command_key_hash = ?) AS admitted_digest, (SELECT COUNT(*) FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION' AND state IN ('DELETING', 'DELETED') AND COALESCE(compacted_through_revision, 0) = 0) AS sealed
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|SELECT 1 FROM ma_session_head WHERE tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION' AND (state <> 'ACTIVE' OR recovery_status <> 'READY')
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|SELECT 1 FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status = 'RECOVERY_BLOCKED' LIMIT 1
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|SELECT session_id FROM ma_session_head WHERE tenant_id = ? AND session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|SELECT tenant_id, session_id, operation_id FROM ma_operation WHERE operation_kind = 'TASK_CANCEL' AND state IN ('PENDING', 'RUNNING') AND delivery_state = 'PENDING' AND available_at <= ? AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_operation.tenant_id AND private_scope.session_id = ma_operation.session_id AND private_scope.is_csi_guard = FALSE) ORDER BY available_at LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|SELECT workspace_id, journal_revision, compacted_through_revision FROM ma_session_head WHERE tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|UPDATE ma_session SET cwd_relative = ?, context_revision = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentExecutionOperations.java|UPDATE ma_session SET title = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_operation.tenant_id AND private_scope.session_id = ma_operation.session_id AND private_scope.is_csi_guard = FALSE) ORDER BY claim_until LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING') AND (status = 'CANCELLING' OR error_code IS NULL OR error_code <> '
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|SELECT creator_actor_key FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|SELECT is_csi_guard FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|SELECT parent_session_id, parent_child_run_id, creator_actor_key FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|SELECT tenant_id, session_id, operation_id FROM ma_operation WHERE operation_kind IN ('CLOSE', 'ARCHIVE', 'DELETE', 'CWD_CHANGE') AND state IN ('PENDING', 'RUNNING', 'RECOVERY_BLOCKED') AND delivery_state IN ('PENDING', 'BLOCKED') AND available_at <= ? AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_operation.tenant_id AND private_scope.session_id = ma_operation.session_id AND private_scope.is_csi_guard = FALSE) ORDER BY available_at LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session SET status = 'CLOSED', gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session SET status = 'DELETED', harness_boot_id = NULL, harness_event_epoch = NULL, harness_last_event_id = 0, deleted_at = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session SET status = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session SET status = ?, harness_event_epoch = NULL, harness_last_event_id = 0, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session_head SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session_head SET operation_id = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND harness_session_id = ? AND (phase = 'LIFECYCLE_ONLY' AND operation_id IS NULL OR phase = 'DRAINING' AND operation_id = ?)
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session_head SET operation_id = NULL, claim_lease_until = NULL WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND harness_session_id = ? AND operation_id = ? AND phase = 'LIFECYCLE_ONLY'
com/alibaba/qwen/code/managedagent/persistence/AgentLifecycleOperations.java|UPDATE ma_session_head SET writer_lease_until = GREATEST(writer_lease_until, (
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT MIN(e.sequence_id) FROM ma_public_event e JOIN ma_turn t ON t.tenant_id = e.tenant_id AND t.session_id = e.session_id AND t.turn_id = e.turn_id WHERE e.tenant_id = ? AND e.session_id = ? AND e.stream_kind = 'SESSION' AND e.stream_id = X'' AND e.event_type = 'turn.accepted' AND t.status IN ('ACCEPTED', 'RUNNING', 'CANCELLING')
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT covered_sequence FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X'' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT covered_sequence, projection_version, last_sequence, replay_floor_sequence FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT is_csi_guard FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT s.replay_floor_sequence, s.covered_sequence FROM ma_event_stream s WHERE s.tenant_id = ? AND s.session_id = ? AND s.stream_kind = 'SESSION' AND s.stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT s.session_id, s.covered_sequence FROM ma_event_stream s WHERE s.stream_kind = 'SESSION' AND s.stream_id = X'' AND s.tenant_id = ? AND s.session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT s.tenant_id, s.session_id FROM ma_event_stream s WHERE s.stream_kind = 'SESSION' AND s.stream_id = X'' AND s.covered_sequence > s.replay_floor_sequence AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = s.tenant_id AND private_scope.session_id = s.session_id AND private_scope.is_csi_guard = FALSE) AND NOT EXISTS (SELECT 1 FROM ma_turn t JOIN ma_public_event e ON e.tenant_id = t.tenant_id AND e.session_id = t.session_id AND e.turn_id = t.turn_id WHERE t.tenant_id = s.tenant_id AND t.session_id = s.session_id AND t.status IN ('ACCEPTED', 'RUNNING', 'CANCELLING') AND e.stream_kind = 'SESSION' AND e.stream_id = X'' AND e.event_type = 'turn.accepted' AND e.sequence_id <= s.replay_floor_sequence + 1) ORDER BY s.gmt_modified ASC LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|SELECT s.tenant_id, s.session_id FROM ma_session s JOIN ma_event_stream p ON p.tenant_id = s.tenant_id AND p.session_id = s.session_id AND p.stream_kind = 'SESSION' AND p.stream_id = X'' WHERE s.session_kind = 'PUBLIC' AND s.is_csi_guard = FALSE AND s.retired_at IS NULL AND s.status <> 'DELETED' AND p.is_projection_pending = TRUE ORDER BY p.gmt_modified ASC LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|UPDATE ma_event_stream SET covered_sequence = ?, gmt_modified = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|UPDATE ma_event_stream SET gmt_modified = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|UPDATE ma_event_stream SET projection_version = projection_version + 1, gmt_modified = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|UPDATE ma_event_stream SET replay_floor_sequence = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentMessageProjection.java|UPDATE ma_message SET item_status = 'failed', last_sequence = CASE WHEN last_sequence < ? THEN ? ELSE last_sequence END, gmt_modified = ?, revision = revision + 1 WHERE tenant_id = ? AND session_id = ? AND item_status = 'in_progress' AND last_sequence < ? AND NOT EXISTS (SELECT 1 FROM ma_public_event terminal WHERE terminal.stream_kind = 'SESSION' AND terminal.stream_id = X'' AND terminal.tenant_id = ma_message.tenant_id AND terminal.session_id = ma_message.session_id AND terminal.turn_id = ma_message.turn_id AND terminal.event_type IN ('turn.completed', 'turn.failed', 'turn.cancelled')) AND NOT EXISTS (SELECT 1 FROM ma_turn live WHERE live.tenant_id = ma_message.tenant_id AND live.session_id = ma_message.session_id AND live.turn_id = ma_message.turn_id AND live.status IN ('ACCEPTED', 'RUNNING', 'CANCELLING'))
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|, creator_actor_key, approval_mode, ?, ?, ?, ? FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|INSERT INTO ma_event_stream (tenant_id, session_id, stream_kind, stream_id, covered_sequence, gmt_modified) VALUES (?, ?, 'SESSION', '', 0, ?)
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|INSERT INTO ma_session (tenant_id, session_id, agent_id, agent_revision, agent_definition_digest, title, status, gmt_create, gmt_modified, workspace_id, workspace_generation, workspace_storage_id, cwd_relative, context_config_ref, context_revision, workspace_config_ref, workspace_policy_ref, tool_profile, creator_actor_key, approval_mode, parent_session_id, root_session_id, parent_child_run_id, child_depth) SELECT tenant_id, ?, agent_id, agent_revision, agent_definition_digest, ?, 'ACTIVE', ?, ?, workspace_id, workspace_generation, workspace_storage_id,
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|INSERT INTO ma_session (tenant_id, session_id, agent_id, agent_revision, agent_definition_digest, title, status, gmt_create, gmt_modified, workspace_id, workspace_generation, workspace_storage_id, cwd_relative, context_config_ref, context_revision, workspace_config_ref, workspace_policy_ref, tool_profile, creator_actor_key, owner_actor_key, runtime_request_key, approval_mode, is_plan_enabled, selected_approval_mode, approval_revision, model_id, model_revision) VALUES (?, ?, ?, ?, ?, ?, 'ACTIVE', ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|SELECT COALESCE(owner_actor_key, creator_actor_key) FROM ma_session WHERE tenant_id=? AND session_id=?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|SELECT runtime_request_key FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|UPDATE ma_session SET public_child_agents_version=1 WHERE tenant_id=? AND session_id=?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionAdmissions.java|UPDATE ma_session SET public_child_agents_version=1, owner_actor_key=?, approval_mode=?, selected_approval_mode=NULL, approval_revision=0, model_id=?, model_revision=1 WHERE tenant_id=? AND session_id=?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_operation.tenant_id AND private_scope.session_id = ma_operation.session_id AND private_scope.is_csi_guard = FALSE) LIMIT 100
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|FROM ma_operation WHERE operation_kind = 'RENAME' AND delivery_state = 'PENDING' AND state = 'PENDING' AND available_at <= ? AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_operation.tenant_id AND private_scope.session_id = ma_operation.session_id AND private_scope.is_csi_guard = FALSE) ORDER BY available_at LIMIT 100
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|INSERT INTO ma_turn (tenant_id, session_id, turn_id, prompt_id, input_json, payload_digest, status, gmt_create, gmt_modified, model_id, model_revision, approval_mode, approval_revision, is_plan_enabled, permission_rules_json) SELECT ?, ?, ?, ?, ?, ?, 'ACCEPTED', ?, ?, model_id, CASE WHEN model_id IS NULL THEN NULL ELSE model_revision END, CASE WHEN ((agent_id=? AND agent_definition_digest IS NULL) OR (agent_id<>? AND agent_definition_digest IS NOT NULL)) AND workspace_id IS NOT NULL AND tool_profile IN ('hosted-workspace-files/1', 'hosted-workspace-shell/1','hosted-workspace-files/3') THEN COALESCE(selected_approval_mode, approval_mode) ELSE NULL END, CASE WHEN ((agent_id=? AND agent_definition_digest IS NULL) OR (agent_id<>? AND agent_definition_digest IS NOT NULL)) AND workspace_id IS NOT NULL AND tool_profile IN ('hosted-workspace-files/1', 'hosted-workspace-shell/1','hosted-workspace-files/3') THEN approval_revision ELSE NULL END, CASE WHEN ((agent_id=? AND agent_definition_digest IS NULL) OR (agent_id<>? AND agent_definition_digest IS NOT NULL)) AND workspace_id IS NOT NULL AND tool_profile IN ('hosted-workspace-files/1', 'hosted-workspace-shell/1','hosted-workspace-files/3') THEN is_plan_enabled ELSE NULL END, CASE WHEN ((agent_id=? AND agent_definition_digest IS NULL) OR (agent_id<>? AND agent_definition_digest IS NOT NULL)) AND workspace_id IS NOT NULL AND tool_profile IN ('hosted-workspace-files/1', 'hosted-workspace-shell/1','hosted-workspace-files/3') THEN permission_rules_json ELSE NULL END FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|SELECT title_revision FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|SELECT title_revision FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC'
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|UPDATE ma_session SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|UPDATE ma_session SET status = 'CLOSED', gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|UPDATE ma_session SET title = ?, harness_boot_id = COALESCE(harness_boot_id, ?), gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionCommands.java|UPDATE ma_turn SET status = 'CANCELLING', retry_after = NULL, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND status IN ('ACCEPTED', 'RUNNING')
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT 1 FROM ma_session_head WHERE tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION' AND (state <> 'ACTIVE' OR recovery_status <> 'READY')
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT 1 FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND (status IN ('RECOVERY_BLOCKED', 'CANCELLING') OR status IN ('ACCEPTED', 'RUNNING') AND error_code IN (?, ?, ?)) LIMIT 1
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING')
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id=? AND session_id=?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT approval_revision, permission_rules_json, is_plan_enabled FROM ma_session WHERE tenant_id=? AND session_id=? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT is_plan_enabled FROM ma_session WHERE tenant_id=? AND session_id=? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT model_revision FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT turn_id FROM ma_turn WHERE tenant_id=? AND session_id=? AND is_submission_attempted=TRUE LIMIT 1 FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|SELECT turn_id FROM ma_turn WHERE tenant_id=? AND session_id=? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING') LIMIT 1 FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|UPDATE ma_session SET model_id = ?, model_revision = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND model_revision = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionPolicies.java|UPDATE ma_session SET selected_approval_mode = ?, approval_revision = ?, is_plan_enabled = ?, permission_rules_json = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND approval_revision = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|, COALESCE(es.last_sequence, 0) AS list_last_sequence, COALESCE(es.replay_floor_sequence, 0) AS list_floor_sequence, w.tenant_id AS worktree_tenant_id, w.session_id AS worktree_session_id, w.workspace_id AS worktree_workspace_id, w.worktree_id AS worktree_worktree_id, w.state AS worktree_state, w.plan_json AS worktree_plan_json, w.identity_json AS worktree_identity_json, w.operation_id AS worktree_operation_id, w.revision AS worktree_revision, w.failure_code AS worktree_failure_code, w.owner_actor_key AS worktree_owner_actor_key, o.claim_owner AS worktree_claim_owner, o.claim_generation AS worktree_claim_generation, o.claim_until AS worktree_claim_until, o.phase AS worktree_phase, o.attempt_count AS worktree_attempt_count FROM ma_session LEFT JOIN ma_event_stream es ON es.tenant_id = ma_session.tenant_id AND es.session_id = ma_session.session_id AND es.stream_kind = 'SESSION' AND es.stream_id = X'' LEFT JOIN ma_session_worktree w ON w.tenant_id = ma_session.tenant_id AND w.session_id = ma_session.session_id LEFT JOIN ma_operation o ON o.operation_kind = 'SESSION_WORKTREE' AND o.tenant_id = w.tenant_id AND o.operation_id = w.operation_id WHERE ma_session.session_kind = 'PUBLIC' AND ma_session.tenant_id = ? AND ma_session.status <> 'DELETED' AND (ma_session.workspace_id IS NULL OR EXISTS (SELECT 1 FROM ma_workspace_access wa WHERE wa.tenant_id = ma_session.tenant_id AND wa.workspace_id = ma_session.workspace_id AND wa.actor_id = ? AND wa.role IN ('READER', 'OPERATOR', 'OWNER')))
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|AND (ma_session.gmt_create < ? OR (ma_session.gmt_create = ? AND ma_session.session_id < ?))
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|AND LOCATE(LOWER(?), LOWER(COALESCE(ma_session.title, ''))) > 0
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|AND ma_session.status <> 'ARCHIVED'
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|AND ma_session.status = 'ARCHIVED'
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|FROM ma_turn WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND turn_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|FROM ma_turn WHERE tenant_id = ? AND session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|FROM ma_turn turn_record JOIN (SELECT event.session_id, event.turn_id FROM ma_public_event event JOIN (SELECT accepted.session_id, MAX(accepted.sequence_id) AS max_sequence FROM ma_public_event accepted WHERE accepted.stream_kind = 'SESSION' AND accepted.stream_id = X'' AND accepted.tenant_id = ? AND accepted.session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|ORDER BY ma_session.gmt_create DESC, ma_session.session_id DESC LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT * FROM (SELECT o.session_id, o.operation_id, o.operation_kind, o.state, o.failure_code, ROW_NUMBER() OVER (PARTITION BY o.session_id ORDER BY CASE WHEN o.state IN ('PENDING', 'RUNNING', 'RECOVERY_BLOCKED') THEN 0 ELSE 1 END, o.gmt_modified DESC, o.gmt_create DESC, o.operation_id DESC) AS lifecycle_rank FROM ma_operation o JOIN ma_session s ON s.tenant_id = o.tenant_id AND s.session_id = o.session_id WHERE o.tenant_id = ? AND o.session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT model_id, model_revision FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND prompt_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT parent_session_id, root_session_id, parent_child_run_id, child_depth FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT s.session_id, s.parent_session_id, s.workspace_id, s.workspace_generation, s.workspace_storage_id, CASE WHEN r.workspace_id IS NOT NULL AND a.actor_id IS NOT NULL THEN TRUE ELSE FALSE END AS creator_can_execute FROM ma_session s LEFT JOIN ma_workspace r ON r.tenant_id = s.tenant_id AND r.workspace_id = s.workspace_id AND r.workspace_generation = s.workspace_generation AND r.storage_id = s.workspace_storage_id AND r.state = 'ACTIVE' LEFT JOIN ma_workspace_access a ON a.tenant_id = r.tenant_id AND a.workspace_id = r.workspace_id AND a.actor_id = s.creator_actor_key AND a.role IN ('OPERATOR', 'OWNER') WHERE s.tenant_id = ? AND s.session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT session_id FROM ma_session WHERE tenant_id=? AND COALESCE(owner_actor_key, creator_actor_key)=? AND session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT session_id, COALESCE(selected_approval_mode, approval_mode) AS mode, approval_revision, is_plan_enabled, permission_rules_json FROM ma_session WHERE tenant_id=? AND session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT session_id, model_id, model_revision FROM ma_session WHERE tenant_id = ? AND session_id IN (
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|SELECT t.approval_mode, t.approval_revision, t.is_plan_enabled, t.permission_rules_json, s.approval_revision AS selected_revision, s.agent_id, s.agent_definition_digest, s.workspace_id, s.tool_profile FROM ma_turn t JOIN ma_session s ON s.tenant_id=t.tenant_id AND s.session_id=t.session_id WHERE t.tenant_id=? AND t.session_id=? AND t.prompt_id=?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|WHERE ma_session.session_kind = 'PUBLIC' AND ma_session.session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentSessionQueries.java|ma_session
com/alibaba/qwen/code/managedagent/persistence/AgentStoreRows.java|, es.last_sequence AS list_last_sequence, es.replay_floor_sequence AS list_floor_sequence FROM ma_session LEFT JOIN ma_event_stream es ON es.tenant_id = ma_session.tenant_id AND es.session_id = ma_session.session_id AND es.stream_kind = 'SESSION' AND es.stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/AgentStoreRows.java|FROM ma_session WHERE ma_session.session_kind = 'PUBLIC' AND ma_session.tenant_id = ? AND ma_session.session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentStoreRows.java|FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND turn_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentStoreRows.java|FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND turn_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentStoreRows.java|SELECT last_sequence, replay_floor_sequence FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X'' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentStoreRows.java|WHERE ma_session.session_kind = 'PUBLIC' AND ma_session.tenant_id = ? AND ma_session.session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentStoreRows.java|ma_session
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|' AND (dispatch_lease_until IS NULL OR dispatch_lease_until < ?) AND (retry_after IS NULL OR retry_after <= ?) AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_turn.tenant_id AND private_scope.session_id = ma_turn.session_id AND private_scope.is_csi_guard = FALSE) ORDER BY retry_after ASC, gmt_modified ASC LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|')) AND (status = 'CANCELLING' OR NOT EXISTS (SELECT 1 FROM ma_session_worktree w WHERE w.tenant_id = ma_turn.tenant_id AND w.session_id = ma_turn.session_id AND w.state <> 'READY')) AND EXISTS (SELECT 1 FROM ma_session private_scope WHERE private_scope.tenant_id = ma_turn.tenant_id AND private_scope.session_id = ma_turn.session_id AND private_scope.is_csi_guard = FALSE) ORDER BY gmt_modified ASC LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND (status = 'CANCELLING' OR status IN ('ACCEPTED', 'RUNNING') AND error_code = ?)
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|SELECT covered_sequence FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X'' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|SELECT tenant_id, session_id, state, writer_lease_until FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND head_kind = 'MANAGED_SESSION' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|SELECT tenant_id, session_id, turn_id FROM ma_turn WHERE status IN ('ACCEPTED', 'RUNNING') AND error_code = '
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|SELECT tenant_id, session_id, turn_id FROM ma_turn WHERE status IN ('ACCEPTED', 'RUNNING', 'CANCELLING') AND (dispatch_lease_until IS NULL OR dispatch_lease_until < ?) AND (retry_after IS NULL OR retry_after <= ?) AND (status = 'CANCELLING' OR error_code IS NULL OR error_code NOT IN ('
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|SELECT turn_id FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status = 'ACCEPTED' AND is_submission_attempted = FALSE FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_session SET harness_boot_id = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_session SET harness_boot_id = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND harness_boot_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_session SET harness_event_epoch = ?, harness_last_event_id = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_session SET harness_event_epoch = ?, harness_last_event_id = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND (harness_event_epoch = ? OR (harness_event_epoch IS NULL AND ? IS NULL))
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET dispatch_owner = ?, dispatch_lease_until = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING') AND (dispatch_lease_until IS NULL OR dispatch_lease_until < ?) AND (retry_after IS NULL OR retry_after <= ?) AND (status = 'CANCELLING' OR NOT EXISTS (SELECT 1 FROM ma_session_worktree w WHERE w.tenant_id = ma_turn.tenant_id AND w.session_id = ma_turn.session_id AND w.state <> 'READY'))
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET error_code = ?, error_message = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ? AND is_submission_attempted = TRUE AND status IN ('ACCEPTED', 'RUNNING')
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET error_code = ?, error_message = ?, retry_after = ?, dispatch_owner = NULL, dispatch_lease_until = NULL, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ? AND status IN ('ACCEPTED', 'RUNNING')
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET error_code = ?, error_message = ?, retry_after = ?, dispatch_owner = NULL, dispatch_lease_until = NULL, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING') AND (? <> ? OR status <> 'CANCELLING')
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET harness_event_epoch = ?, harness_last_event_id = ?, consecutive_failures = 0, budget_exempt_failures = 0, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET harness_event_epoch = ?, harness_last_event_id = ?, status = ?, error_code = ?, error_message = ?, completed_at = ?, gmt_modified = ?, dispatch_owner = NULL, dispatch_lease_until = NULL, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET is_submission_attempted = FALSE, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ? AND is_submission_attempted = TRUE AND harness_event_epoch IS NULL AND status IN ('ACCEPTED','RUNNING','CANCELLING')
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET is_submission_attempted = TRUE, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ? AND harness_event_epoch IS NULL
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET retry_after = ?, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND (retry_after IS NULL OR retry_after > ?) AND (status = 'CANCELLING' OR status IN ('ACCEPTED', 'RUNNING') AND error_code = ?)
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET retry_count = retry_count + 1, consecutive_failures = consecutive_failures + 1, budget_exempt_failures = budget_exempt_failures + ?, retry_after = ?, dispatch_owner = NULL, dispatch_lease_until = NULL, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING')
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET status = 'CANCELLED', completed_at = ?, gmt_modified = ?, dispatch_owner = NULL, dispatch_lease_until = NULL, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ? AND is_submission_attempted = FALSE
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET status = 'FAILED', error_code = ?, error_message = ?, completed_at = ?, gmt_modified = ?, dispatch_owner = NULL, dispatch_lease_until = NULL, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND status IN
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET status = 'FAILED', error_code = ?, error_message = ?, completed_at = ?, gmt_modified = ?, dispatch_owner = NULL, dispatch_lease_until = NULL, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND status = 'ACCEPTED' AND is_submission_attempted = FALSE
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET status = CASE WHEN status = 'CANCELLING' THEN status ELSE 'RUNNING' END, harness_event_epoch = ?, harness_last_event_id = ?, consecutive_failures = 0, budget_exempt_failures = 0, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ?
com/alibaba/qwen/code/managedagent/persistence/AgentTurnExecution.java|UPDATE ma_turn SET status = CASE WHEN status = 'CANCELLING' THEN status ELSE 'RUNNING' END, harness_event_epoch = ?, harness_last_event_id = ?, consecutive_failures = 0, budget_exempt_failures = 0, gmt_modified = ?, version = version + 1 WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND dispatch_owner = ? AND dispatch_lease_until >= ? AND (harness_event_epoch = ? OR (harness_event_epoch IS NULL AND ? IS NULL))
com/alibaba/qwen/code/managedagent/persistence/AutomationLedgerStore.java|SELECT 1 FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING') LIMIT 1
com/alibaba/qwen/code/managedagent/persistence/AutomationLedgerStore.java|SELECT creator_actor_key FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/AutomationLedgerStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ChannelInstanceStore.java|SELECT r.session_id, MIN(r.gmt_create) AS oldest_due FROM ma_session_record r JOIN ma_channel_binding b ON b.tenant_id = r.tenant_id AND b.session_id = r.session_id JOIN ma_session s ON s.tenant_id = r.tenant_id AND s.session_id = r.session_id AND s.session_kind = 'PUBLIC' AND s.status = 'ACTIVE' WHERE r.record_kind = 'DOMAIN' AND r.tenant_id = ? AND b.channel_id = ? AND r.domain = 'channel_delivery' AND r.delivery_state IN ('planned', 'partial') GROUP BY r.session_id ORDER BY oldest_due, r.session_id LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/ChannelInstanceStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC'
com/alibaba/qwen/code/managedagent/persistence/ChildResultRelayStore.java|SELECT compacted_through_revision FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ChildResultRelayStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND parent_session_id = ? AND parent_child_run_id = ?
com/alibaba/qwen/code/managedagent/persistence/ChildResultRelayStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ChildResultRelayStore.java|SELECT turn_id, status, completed_at, error_code, is_submission_attempted, harness_event_epoch FROM ma_turn WHERE tenant_id = ? AND session_id = ? ORDER BY gmt_create
com/alibaba/qwen/code/managedagent/persistence/ChildWorkspaceStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND parent_session_id = ? AND parent_child_run_id = ?
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|FROM ma_session
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|SELECT COUNT(*) FROM ma_session WHERE session_id = ?
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|SELECT m.session_id FROM ma_session m WHERE m.harness_instance_id = ? AND m.harness_owner_boot_id = ? AND m.is_resource_gc_completed = FALSE AND m.harness_placement_state <> 'RELEASED' AND (m.status NOT IN ('CLOSED', 'ARCHIVED', 'DELETED') OR EXISTS ( SELECT 1 FROM ma_session_head h WHERE h.tenant_id = m.tenant_id AND h.session_id = m.session_id AND h.head_kind = 'MANAGED_SESSION' AND h.state = 'ACTIVE' AND h.writer_lease_until >
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|SELECT o.claim_generation, o.claim_until, o.claim_owner, o.delivery_state, o.lifecycle_protocol_version, f.phase, f.operation_id FROM ma_operation o JOIN ma_session_head f ON f.tenant_id = o.tenant_id AND f.harness_session_id = o.session_id WHERE o.tenant_id = ? AND o.session_id = ? AND o.operation_id = ? AND o.operation_kind = ? AND f.tenant_key = ? AND f.harness_key = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|SELECT state, writer_lease_until, activation_phase, activation_expires_at, activation_head_revision, journal_revision, activation_epoch FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|SELECT status, session_kind, workspace_id, is_csi_guard FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|UPDATE ma_session SET harness_instance_id = ?, harness_owner_boot_id = ?, harness_placement_epoch = 1, harness_placement_state = 'ACTIVE' WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|UPDATE ma_session SET harness_instance_id = ?, harness_owner_boot_id = ?, harness_placement_epoch = ?, harness_placement_state = 'ACTIVE' WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/HarnessPlacementStore.java|UPDATE ma_session SET harness_placement_state = 'QUIESCING' WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/HostedCleanupDebtStore.java|SELECT r.tenant_id, r.workspace_id, r.session_id, r.owner_key, r.gmt_create, m.inline_bytes FROM ma_resource_ref r JOIN ma_resource m ON m.resource_key = r.resource_key WHERE r.owner_kind = 'HOSTED_CLEANUP' AND m.state = 'REFERENCED' AND m.storage_kind = 'MYSQL_INLINE' AND r.workspace_id IS NOT NULL AND (r.gmt_create > ? OR (r.gmt_create = ? AND r.owner_key > ?)) AND NOT EXISTS (SELECT 1 FROM ma_turn t WHERE t.tenant_id = r.tenant_id AND t.session_id = r.session_id AND t.status IN ('ACCEPTED', 'RUNNING', 'CANCELLING')) ORDER BY r.gmt_create, r.owner_key LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/JdbcSessionRecoveryRepository.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND (status <> 'CANCELLED' OR is_submission_attempted = TRUE OR harness_event_epoch IS NOT NULL)
com/alibaba/qwen/code/managedagent/persistence/JdbcSessionRecoveryRepository.java|SELECT recovery_status, recovery_detail_code FROM ma_session_head WHERE tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/managedagent/persistence/JournalCommit.java|UPDATE ma_session_head SET journal_revision = ?, committed_sequence = ?, is_wake_pending = is_wake_pending OR ?, wake_head_revision = CASE WHEN wake_head_revision = ? THEN ? ELSE wake_head_revision END, cleanup_head_revision = CASE WHEN cleanup_head_revision = ? THEN ? ELSE cleanup_head_revision END, last_commit_digest = ?, activation_epoch = ?, latest_checkpoint_resource_id = COALESCE(?, latest_checkpoint_resource_id), activation_id = ?, activation_phase = ?, activation_event_epoch = ?, activation_expires_at = ?, activation_head_revision = ?, storage_version = ?, gmt_modified = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalCommit.java|UPDATE ma_session_head SET state = 'SEALED', journal_revision = ?, wake_head_revision = CASE WHEN wake_head_revision = ? THEN ? ELSE wake_head_revision END, committed_sequence = ?, last_commit_digest = ?, activation_phase = 'released', activation_head_revision = ?, gmt_modified = ? WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND state = 'ACTIVE' AND journal_revision = ? AND committed_sequence = ? AND last_commit_digest = ?
com/alibaba/qwen/code/managedagent/persistence/JournalFencing.java|SELECT is_csi_guard FROM ma_session WHERE tenant_id = ? AND session_id = ? AND is_csi_guard = TRUE
com/alibaba/qwen/code/managedagent/persistence/JournalFencing.java|SELECT operation_id FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND harness_session_id = ? AND operation_id IS NOT NULL FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalFencing.java|SELECT phase FROM ma_session_head WHERE phase <> 'OPEN' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND harness_session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalLifecycleAuthorization.java|SELECT agent_id, agent_definition_digest, tool_profile, workspace_id, approval_mode, selected_approval_mode, approval_revision, permission_rules_json FROM ma_session WHERE tenant_id=? AND session_id=? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalLifecycleAuthorization.java|SELECT phase FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND harness_session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalLifecycleAuthorization.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalResourceReads.java|SELECT is_csi_guard FROM ma_session WHERE tenant_id = ? AND session_id = ? AND is_csi_guard = TRUE
com/alibaba/qwen/code/managedagent/persistence/JournalStoreRows.java|FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/managedagent/persistence/JournalStoreRows.java|FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalStoreRows.java|INSERT IGNORE INTO ma_event_stream (tenant_id, session_id, stream_kind, stream_id, gmt_modified) VALUES (?, ?, 'SESSION', X'', ?)
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|INSERT IGNORE INTO ma_session_head (tenant_key, harness_key, tenant_id, harness_session_id, session_id, head_kind, phase, gmt_create, gmt_modified) VALUES (?, ?, ?, ?, ?, 'HARNESS', 'OPEN',
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|INSERT INTO ma_session_head (tenant_key, harness_key, harness_session_id, head_kind, tenant_id, workspace_id, session_id, storage_version, state, writer_generation, writer_id, writer_lease_until, lease_token_hash, journal_revision, wake_head_revision, cleanup_head_revision, committed_sequence, activation_epoch, compacted_through_revision, recovery_status, gmt_create, gmt_modified) VALUES (?, ?, ?, 'MANAGED_SESSION', ?, ?, ?, ?, 'ACTIVE', 1, ?, ?, ?, 0, 0, 0, 0, 0, 0, 'READY', ?, ?)
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|SELECT head_kind FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|SELECT session_kind, workspace_id, workspace_storage_id FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ? AND (workspace_id IS NOT NULL OR session_kind = 'PUBLIC') FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|SELECT writer_lease_until FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND state = 'ACTIVE' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session SET harness_placement_state = 'QUIESCING' WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session SET harness_placement_state = 'RELEASED' WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session_head SET activation_expires_at = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session_head SET head_kind = 'MANAGED_SESSION', workspace_id = ?, storage_version = ?, state = 'ACTIVE', writer_generation = 1, writer_id = ?, writer_lease_until = ?, lease_token_hash = ?, journal_revision = 0, wake_head_revision = 0, cleanup_head_revision = 0, committed_sequence = 0, activation_epoch = 0, compacted_through_revision = 0, recovery_status = 'READY', gmt_modified = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'HARNESS'
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session_head SET recovery_status = ?, recovery_detail_code = ?, gmt_modified = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session_head SET state = 'ACTIVE', writer_generation = ?, writer_id = ?, writer_lease_until = ?, lease_token_hash = ?, gmt_modified = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session_head SET state = 'SEALED', gmt_modified = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session_head SET state = 'SEALED', gmt_modified = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/managedagent/persistence/JournalWriterLifecycle.java|UPDATE ma_session_head SET writer_lease_until = ?, gmt_modified = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/LocalStorageOwners.java|SELECT /*! STRAIGHT_JOIN */ 1 FROM ma_session s USE INDEX (idx_ma_session_storage_scope) JOIN ma_session_head h ON h.tenant_key = s.tenant_key AND h.harness_key = s.session_key JOIN ma_workspace w ON w.tenant_id = s.tenant_id AND w.workspace_id = h.workspace_id WHERE s.tenant_id = ? AND s.workspace_storage_id IS NULL AND s.is_resource_gc_completed = FALSE AND h.tenant_key = ? AND h.head_kind = 'MANAGED_SESSION' AND w.tenant_id = ? AND w.storage_id = ? LIMIT 1
com/alibaba/qwen/code/managedagent/persistence/LocalStorageOwners.java|SELECT 1 FROM ma_session WHERE tenant_id = ? AND workspace_storage_id = ? AND is_resource_gc_completed = FALSE LIMIT 1
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|FROM ma_session_record r JOIN ma_session s ON s.tenant_id=r.tenant_id AND s.session_id=r.session_id WHERE r.tenant_id=? AND r.record_kind='ACTION' AND r.state='requested' AND s.deleted_at IS NULL AND (s.session_id=? OR s.parent_session_id=? AND s.public_child_agents_version=1)
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT COUNT(*) FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC'
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT COUNT(*) FROM ma_turn t JOIN ma_session s ON s.tenant_id=t.tenant_id AND s.session_id=t.session_id WHERE t.tenant_id=? AND t.session_id=? AND t.prompt_id=? AND t.is_plan_enabled=TRUE AND s.session_kind='PUBLIC' AND s.parent_session_id IS NULL
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT approval_mode FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC'
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT owner_actor_key, creator_actor_key, workspace_id, tool_profile FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC'
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT session_id FROM ma_session WHERE tenant_id=? AND session_id=? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT status, workspace_storage_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|SELECT turn_id FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND prompt_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedActionStore.java|UPDATE ma_session SET is_plan_enabled=FALSE, approval_revision=approval_revision+1, version=version+1, gmt_modified=? WHERE tenant_id=? AND session_id=? AND is_plan_enabled=TRUE AND EXISTS (SELECT 1 FROM ma_turn WHERE tenant_id=? AND session_id=? AND prompt_id=? AND is_plan_enabled=TRUE AND status IN ('ACCEPTED','RUNNING'))
com/alibaba/qwen/code/managedagent/persistence/ManagedExtensionAgentLaunch.java|SELECT COALESCE(selected_approval_mode, approval_mode) AS mode, approval_revision FROM ma_session WHERE tenant_id=? AND session_id=? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedExtensionCommandVerifier.java|SELECT COALESCE(selected_approval_mode, approval_mode) FROM ma_session WHERE tenant_id=? AND session_id=?
com/alibaba/qwen/code/managedagent/persistence/ManagedExtensionRecordStore.java|SELECT COUNT(*) FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC' AND workspace_id = ? AND workspace_storage_id IS NOT NULL
com/alibaba/qwen/code/managedagent/persistence/ManagedExtensionRecordStore.java|SELECT parent_session_id, parent_child_run_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedExtensionRecordStore.java|SELECT r.session_id, r.settled_at, u.byte_length, u.sha256, u.inline_bytes FROM ma_session_record r JOIN ma_resource u ON u.session_scope_key = r.session_scope_key AND u.resource_id = r.record_resource_id AND u.tenant_id = r.tenant_id AND u.session_id = r.session_id AND u.workspace_id = r.workspace_id JOIN ma_session s ON s.tenant_id = r.tenant_id AND s.session_id = r.session_id AND s.workspace_id = r.workspace_id WHERE r.tenant_id = ? AND (
com/alibaba/qwen/code/managedagent/persistence/ManagedExtensionRecordStore.java|SELECT session_id FROM ma_session WHERE session_kind = 'PUBLIC' AND tenant_id = ? AND parent_session_id = ? AND parent_child_run_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedExtensionRecordStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedLegacySessionGuard.java|SELECT is_csi_guard FROM ma_session
com/alibaba/qwen/code/managedagent/persistence/ManagedProjectionResourceCollector.java|AND NOT EXISTS (SELECT 1 FROM ma_session s WHERE s.tenant_id = ma_resource.tenant_id AND s.session_id = ma_resource.session_id AND s.is_csi_guard = TRUE) ORDER BY retention_until, resource_key LIMIT
com/alibaba/qwen/code/managedagent/persistence/ManagedProjectionResourceCollector.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND session_id = ? AND is_recovery_protected = TRUE
com/alibaba/qwen/code/managedagent/persistence/ManagedProjectionResourceCollector.java|SELECT tenant_id FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION' AND recovery_status <> 'READY'
com/alibaba/qwen/code/managedagent/persistence/ManagedRuntimeRetentionGuard.java|SELECT 1 FROM ma_runtime_session s JOIN ma_session_head h ON h.tenant_key = ? AND h.tenant_id = s.tenant_id AND h.session_id = s.harness_session_id WHERE s.binding_id = ? AND s.runtime_generation = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedRuntimeRetentionGuard.java|SELECT 1 FROM ma_session WHERE tenant_id = ? AND session_id = ? AND is_csi_guard = TRUE LIMIT 1 FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedRuntimeRetentionGuard.java|SELECT 1 FROM ma_session_head h WHERE h.tenant_key = ? AND h.harness_key = ? AND h.tenant_id = ? AND h.session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedRuntimeRetentionGuard.java|SELECT tenant_id, session_id, parent_session_id, parent_child_run_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionModelConfigs.java|SELECT model_config_digest FROM ma_session WHERE tenant_id=? AND session_id=?
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionModelConfigs.java|SELECT model_config_digest, model_config_key_id, model_config_ciphertext FROM ma_session WHERE tenant_id=? AND session_id=?
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionModelConfigs.java|UPDATE ma_session SET model_config_digest=?, model_config_key_id=?, model_config_ciphertext=? WHERE tenant_id=? AND session_id=? AND model_config_digest IS NULL
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|SELECT retired_at FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|SELECT retired_at, retirement_generation, is_recovery_protected FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|SELECT stream_kind, stream_id FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND artifact_refs_resource_key IS NOT NULL LIMIT ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|SELECT tenant_id, session_id, harness_session_id, head_kind, state, journal_revision, compacted_through_revision, writer_id, writer_lease_until, latest_checkpoint_resource_id, recovery_status FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|UPDATE ma_event_stream SET artifact_refs_resource_key = NULL WHERE tenant_id = ? AND session_id = ? AND stream_kind = ? AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|UPDATE ma_event_stream SET covered_sequence = last_sequence WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X''
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|UPDATE ma_event_stream SET replay_floor_sequence = GREATEST(replay_floor_sequence, ?) WHERE tenant_id = ? AND session_id = ? AND stream_kind = ? AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|UPDATE ma_session SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/ManagedSessionRetirementStore.java|UPDATE ma_session_head SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|INSERT INTO ma_event_stream (tenant_id,session_id,stream_kind,stream_id,gmt_modified) VALUES (?,?,'TASK',?,?) ON DUPLICATE KEY UPDATE stream_id = stream_id
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|SELECT artifact_refs_resource_key,output_ranges_json FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'TASK' AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|SELECT last_sequence FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'TASK' AND stream_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|SELECT last_sequence, replay_floor_sequence, artifact_refs_resource_key FROM ma_event_stream WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'TASK' AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|SELECT workspace_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|SELECT workspace_id,status,retired_at FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|UPDATE ma_event_stream SET artifact_refs_resource_key = ?, gmt_modified = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'TASK' AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|UPDATE ma_event_stream SET last_sequence = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'TASK' AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|UPDATE ma_event_stream SET output_ranges_json = ?, gmt_modified = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'TASK' AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedTaskEventStore.java|UPDATE ma_event_stream SET replay_floor_sequence = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'TASK' AND stream_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedToolDetailsStore.java|SELECT t.prompt_id, m.attributes_json FROM ma_message m JOIN ma_turn t ON t.tenant_id = m.tenant_id AND t.session_id = m.session_id AND t.turn_id = m.turn_id WHERE m.tenant_id = ? AND m.session_id = ? AND m.item_id = ? AND m.item_type = 'tool_call'
com/alibaba/qwen/code/managedagent/persistence/ManagedToolResultProjector.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedToolResultProjector.java|SELECT t.tenant_id, t.session_id, t.prompt_id, t.turn_id, s.workspace_id FROM ma_turn t JOIN ma_session s ON s.tenant_id = t.tenant_id AND s.session_id = t.session_id WHERE t.tenant_id = ? AND t.session_id = ? AND t.prompt_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedToolResultStore.java|AS due_at FROM ma_operation WHERE operation_kind = 'TOOL_RESULT_PROJECTION' AND NOT EXISTS (SELECT 1 FROM ma_session s WHERE s.tenant_id = ma_operation.tenant_id AND s.session_id = ma_operation.session_id AND s.is_csi_guard = TRUE) AND state = ? AND
com/alibaba/qwen/code/managedagent/persistence/ManagedToolResultStore.java|SELECT retirement_generation FROM ma_session WHERE tenant_key = ? AND session_key = ? AND retired_at IS NOT NULL
com/alibaba/qwen/code/managedagent/persistence/ManagedToolResultStore.java|SELECT s.tenant_id, s.session_id, s.workspace_id, s.status, e.last_sequence FROM ma_session s JOIN ma_event_stream e ON e.tenant_id = s.tenant_id AND e.session_id = s.session_id AND e.stream_kind = 'SESSION' AND e.stream_id = X'' WHERE s.tenant_id = ? AND s.session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING', 'RECOVERY_BLOCKED')
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|SELECT DISTINCT m.tenant_id, m.session_id, q.last_dispatch_at FROM ma_user_message m JOIN ma_session s ON s.tenant_id = m.tenant_id AND s.session_id = m.session_id JOIN ma_user_message_queue q ON q.tenant_id = m.tenant_id AND q.session_id = m.session_id WHERE s.status = 'ACTIVE' AND q.is_paused = FALSE AND m.state = 'queued' AND NOT EXISTS (SELECT 1 FROM ma_turn t WHERE t.tenant_id = m.tenant_id AND t.session_id = m.session_id AND t.status IN ('ACCEPTED', 'RUNNING', 'CANCELLING', 'RECOVERY_BLOCKED')) AND NOT EXISTS (SELECT 1 FROM ma_user_message blocked WHERE blocked.tenant_id = m.tenant_id AND blocked.session_id = m.session_id AND blocked.state IN ('claimed', 'recovery_blocked')) ORDER BY q.last_dispatch_at, m.tenant_id, m.session_id LIMIT 32
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|SELECT context_revision FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|SELECT prompt_id FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND turn_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|SELECT turn_id FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND prompt_id = ? AND status IN ('ACCEPTED', 'RUNNING')
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|SELECT turn_id, status FROM ma_turn WHERE tenant_id = ? AND session_id = ? ORDER BY gmt_create DESC, turn_id DESC LIMIT 1
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|UPDATE ma_user_message SET state = 'recovery_blocked' WHERE tenant_id = ? AND session_id = ? AND state = 'claimed' AND turn_id IN (SELECT turn_id FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status IN ('COMPLETED', 'FAILED', 'CANCELLED'))
com/alibaba/qwen/code/managedagent/persistence/ManagedUserMessageStore.java|UPDATE ma_user_message SET state = 'withdrawn' WHERE state = 'queued' AND EXISTS (SELECT 1 FROM ma_session s WHERE s.tenant_id = ma_user_message.tenant_id AND s.session_id = ma_user_message.session_id AND s.status <> 'ACTIVE')
com/alibaba/qwen/code/managedagent/persistence/ManagedWorkspaceRegistry.java|SELECT COALESCE(owner_actor_key, creator_actor_key) FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ManagedWorkspaceRegistry.java|SELECT creator_actor_key FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ResidentWorkspaceRetirementStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND workspace_id = ? AND session_kind = 'PUBLIC' AND status NOT IN ('CLOSED', 'ARCHIVED', 'DELETED') LIMIT 1 FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ResidentWorkspaceRetirementStore.java|SELECT session_id FROM ma_session_head WHERE tenant_id = ? AND workspace_id = ? AND head_kind = 'MANAGED_SESSION' AND (state IS NULL OR state NOT IN ('SEALED', 'DELETED') OR writer_lease_until >
com/alibaba/qwen/code/managedagent/persistence/ResidentWorkspaces.java|SELECT COUNT(*) FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC' AND parent_session_id IS NULL AND tool_profile = ? AND status IN ('CLOSING', 'DELETING')
com/alibaba/qwen/code/managedagent/persistence/ResidentWorkspaces.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND workspace_id = ? AND session_kind = 'PUBLIC' AND status NOT IN ('CLOSED', 'ARCHIVED', 'DELETED') FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ResidentWorkspaces.java|SELECT workspace_id, workspace_generation, workspace_storage_id, cwd_relative, context_config_ref, context_revision, tool_profile, status, parent_session_id FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/SessionMessageRelayStore.java|SELECT parent_session_id, parent_child_run_id FROM ma_session WHERE tenant_id = ? AND session_id = ? AND parent_session_id IS NOT NULL
com/alibaba/qwen/code/managedagent/persistence/SessionResourceCollectionCollector.java|SELECT retired_at FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/SessionResourceCollectionCollector.java|SELECT retired_at, is_recovery_protected FROM ma_session WHERE tenant_key = ? AND session_key = ? AND retired_at IS NOT NULL
com/alibaba/qwen/code/managedagent/persistence/SessionResourceCollectionCollector.java|SELECT s.tenant_id, s.session_id, s.session_scope_key FROM ma_session s WHERE s.is_csi_guard = FALSE AND s.retired_at <= ? AND NOT EXISTS (SELECT 1 FROM ma_operation o WHERE o.operation_kind = 'SESSION_RESOURCE_GC' AND o.scope_key = s.session_scope_key AND o.target_key = s.session_scope_key LIMIT 1) ORDER BY s.retired_at LIMIT 32
com/alibaba/qwen/code/managedagent/persistence/SessionResourceCollectionCollector.java|SELECT scope_key, tenant_id, session_id FROM ma_operation WHERE operation_kind = 'SESSION_RESOURCE_GC' AND NOT EXISTS (SELECT 1 FROM ma_session s WHERE s.tenant_id = ma_operation.tenant_id AND s.session_id = ma_operation.session_id AND s.is_csi_guard = TRUE) AND state <> 'SUCCEEDED' AND available_at >= 0 AND available_at <= ? AND (claim_owner = ? OR claim_until IS NULL OR claim_until <= ?) ORDER BY available_at, operation_key LIMIT 32
com/alibaba/qwen/code/managedagent/persistence/SessionWorktreeStore.java|SELECT DISTINCT w.tenant_id, w.session_id, w.failure_code FROM ma_session_worktree w JOIN ma_turn t ON t.tenant_id = w.tenant_id AND t.session_id = w.session_id WHERE w.state IN ('FAILED','BLOCKED') AND t.status = 'ACCEPTED' AND t.is_submission_attempted = FALSE LIMIT 20
com/alibaba/qwen/code/managedagent/persistence/SessionWorktreeStore.java|SELECT status FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationAdmissionStore.java|SELECT journal_revision, committed_sequence, storage_version FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationCollector.java|SELECT c.scope_key, c.publication_id, c.tenant_id, c.workspace_id, c.session_id FROM ma_output_capture c WHERE c.retention_state = 'RETIRING' AND NOT EXISTS (SELECT 1 FROM ma_session s WHERE s.tenant_id = c.tenant_id AND s.session_id = c.session_id AND s.is_csi_guard = TRUE) AND NOT EXISTS (SELECT 1 FROM ma_operation o USE INDEX (idx_ma_operation_publication) WHERE o.scope_key = c.scope_key AND o.publication_id = c.publication_id AND o.operation_kind = 'CAPTURE_GC' LIMIT 1) LIMIT 32
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationCollector.java|SELECT is_resource_gc_completed FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationCollector.java|SELECT retired_at FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationCollector.java|SELECT scope_key, publication_id, tenant_id, session_id FROM ma_operation WHERE operation_kind = 'CAPTURE_GC' AND NOT EXISTS (SELECT 1 FROM ma_session s WHERE s.tenant_id = ma_operation.tenant_id AND s.session_id = ma_operation.session_id AND s.is_csi_guard = TRUE) AND state <> 'SUCCEEDED' AND available_at >= 0 AND available_at <= ? AND (claim_owner = ? OR claim_until IS NULL OR claim_until <= ?) ORDER BY available_at, operation_key LIMIT 32
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationDataStore.java|SELECT publication_id, producer_phase, admission_resource_id, receipt_revision, receipt_sequence, CASE WHEN is_quarantined THEN 1 ELSE 0 END AS is_quarantined FROM ma_output_capture WHERE scope_key = ? AND tenant_id = ? AND workspace_id = ? AND session_id = ? AND NOT EXISTS (SELECT 1 FROM ma_session r WHERE r.tenant_key = ? AND r.session_key = ? AND r.retired_at IS NOT NULL) AND publication_id IN (
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|INSERT INTO ma_session (tenant_id, session_id, session_kind, tenant_key, session_key, session_scope_key, gmt_create, gmt_modified) VALUES (?, ?, 'CONTROL', ?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE tenant_key = VALUES(tenant_key), session_key = VALUES(session_key), session_scope_key = VALUES(session_scope_key)
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT l.expires_at, l.retirement_generation, r.retirement_generation AS generation, r.retired_at, CAST(UNIX_TIMESTAMP() AS DECIMAL(20, 0)) * 1000 + EXTRACT(MICROSECOND FROM CURRENT_TIMESTAMP(6)) / 1000 AS db_now FROM ma_read_lease l LEFT JOIN ma_session r ON r.tenant_key = l.tenant_key AND r.session_key = l.session_key AND r.tenant_id = ? AND r.session_id = ? WHERE l.lease_id = ? AND l.tenant_key = ? AND l.session_key = ?
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT retired_at, is_recovery_protected FROM ma_session WHERE tenant_key = ? AND session_key = ? AND retired_at IS NOT NULL
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT retirement_generation FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT retirement_generation FROM ma_session WHERE tenant_key = ? AND session_key = ? AND retired_at IS NOT NULL
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT retirement_generation, retired_at FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT retirement_operation_id AS operation_id FROM ma_session WHERE tenant_key = ? AND session_key = ? AND retired_at IS NOT NULL
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT state FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|SELECT tenant_id, session_id, is_csi_guard FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|THEN 1 ELSE 0 END AS writer_active FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|UPDATE ma_session SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationRetentionStore.java|UPDATE ma_session_head SET state = 'DELETED', writer_id = NULL, writer_lease_until = NULL, lease_token_hash = NULL, latest_checkpoint_resource_id = NULL, gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationStore.java|THEN 1 ELSE 0 END AS writer_live, recovery_status, activation_epoch, journal_revision, activation_id, activation_phase, activation_event_epoch, activation_expires_at, activation_head_revision FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/ToolPublicationStore.java|THEN 1 ELSE 0 END FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/TransportConsumerStore.java|SELECT COALESCE(s.workspace_id, h.workspace_id) FROM ma_session s LEFT JOIN ma_session_head h ON h.tenant_key = ? AND h.harness_key = ? AND h.tenant_id = s.tenant_id AND h.session_id = s.session_id AND h.head_kind = 'MANAGED_SESSION' WHERE s.tenant_id = ? AND s.session_id = ? AND s.session_kind = 'PUBLIC' AND s.retired_at IS NULL
com/alibaba/qwen/code/managedagent/persistence/TransportConsumerStore.java|SELECT e.covered_sequence FROM ma_event_stream e JOIN ma_session s ON s.tenant_id = e.tenant_id AND s.session_id = e.session_id WHERE e.tenant_id = ? AND e.session_id = ? AND e.stream_kind = 'SESSION' AND e.stream_id = X'' AND s.session_kind = 'PUBLIC' AND s.retired_at IS NULL
com/alibaba/qwen/code/managedagent/persistence/TransportConsumerStore.java|SELECT s.status, h.workspace_id, h.state, h.committed_sequence, h.writer_lease_until FROM ma_session s JOIN ma_session_head h ON h.tenant_key = ? AND h.harness_key = ? AND h.tenant_id = s.tenant_id AND h.session_id = s.session_id AND h.head_kind = 'MANAGED_SESSION' WHERE s.tenant_id = ? AND s.session_id = ? AND s.session_kind = 'PUBLIC' AND s.retired_at IS NULL
com/alibaba/qwen/code/managedagent/persistence/TransportConsumerStore.java|SELECT session_id, writer_lease_until FROM ma_session_head WHERE tenant_key = ? AND tenant_id = ? AND head_kind = 'MANAGED_SESSION' AND state = 'ACTIVE' AND writer_id = ? AND harness_key IN (
com/alibaba/qwen/code/managedagent/persistence/TransportConsumerStore.java|UPDATE ma_event_stream SET wake_covered_sequence = ? WHERE tenant_id = ? AND session_id = ? AND stream_kind = 'SESSION' AND stream_id = X'' AND (wake_covered_sequence IS NULL OR wake_covered_sequence < ?)
com/alibaba/qwen/code/managedagent/persistence/WakeRecoveryStore.java|SELECT COUNT(*) FROM ma_session_head h JOIN ma_session s ON s.tenant_id = h.tenant_id AND s.session_id = h.session_id WHERE h.tenant_key = ? AND h.harness_key = ? AND h.tenant_id = ? AND h.session_id = ? AND h.workspace_id = ? AND h.head_kind = 'MANAGED_SESSION' AND h.journal_revision = ? AND h.committed_sequence = ? AND h.compacted_through_revision = 0 AND h.is_wake_scan_pending = TRUE AND
com/alibaba/qwen/code/managedagent/persistence/WakeRecoveryStore.java|SELECT h.tenant_id, h.workspace_id, h.session_id, h.journal_revision, h.committed_sequence, h.compacted_through_revision, s.parent_session_id, s.parent_child_run_id FROM ma_session_head h JOIN ma_session s ON s.tenant_id = h.tenant_id AND s.session_id = h.session_id WHERE h.head_kind = 'MANAGED_SESSION' AND h.is_wake_scan_pending = TRUE AND h.compacted_through_revision = 0 AND h.is_wake_pending = ? AND h.wake_retry_at <=
com/alibaba/qwen/code/managedagent/persistence/WakeRecoveryStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND session_id = ? AND session_kind = 'PUBLIC' AND status = 'ACTIVE' AND retired_at IS NULL AND is_csi_guard = FALSE AND (workspace_id IS NULL OR workspace_id = ?) FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/WakeRecoveryStore.java|UPDATE ma_session_head SET is_wake_pending = ?, wake_head_revision = ? WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND workspace_id = ? AND journal_revision = ? AND compacted_through_revision = 0
com/alibaba/qwen/code/managedagent/persistence/WakeRecoveryStore.java|UPDATE ma_session_head h SET wake_retry_at =
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationHistory.java|ma_session
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationHistory.java|ma_session_head
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationHistoryImage.java|ma_session
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationImage.java|ma_session_head
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationInventory.java|ma_event_stream
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationInventory.java|ma_session
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationInventory.java|ma_session_head
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationInventory.java|ma_turn
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationStore.java|ma_session
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiApplicationStore.java|ma_session_head
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiCheckpointSnapshotStore.java|FROM ma_session_head WHERE tenant_key = ? AND harness_key = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceCsiCheckpointSnapshotStore.java|ma_session_head
com/alibaba/qwen/code/managedagent/persistence/WorkspaceExecutionStore.java|FROM ma_session s
com/alibaba/qwen/code/managedagent/persistence/WorkspaceExecutionStore.java|JOIN ma_turn t ON t.tenant_id = s.tenant_id AND t.session_id = s.session_id AND t.status = 'CANCELLING' AND (t.is_submission_attempted = TRUE OR t.harness_event_epoch IS NOT NULL)
com/alibaba/qwen/code/managedagent/persistence/WorkspaceExecutionStore.java|SELECT COUNT(*) FROM ma_session WHERE tenant_id = ? AND session_id = ? AND parent_session_id IS NULL
com/alibaba/qwen/code/managedagent/persistence/WorkspaceExecutionStore.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND turn_id = ? AND status = 'RUNNING' AND is_submission_attempted = TRUE AND harness_event_epoch IS NOT NULL AND dispatch_owner = ? AND dispatch_lease_until >=
com/alibaba/qwen/code/managedagent/persistence/WorkspaceExecutionStore.java|SELECT parent_session_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceExecutionStore.java|SELECT tenant_id, session_id, parent_session_id, creator_actor_key, workspace_id, workspace_generation, workspace_storage_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceFileStore.java|SELECT * FROM ma_session WHERE tenant_id = ? AND session_id = ? AND status <> 'DELETED'
com/alibaba/qwen/code/managedagent/persistence/WorkspaceFileUploadStore.java|SELECT 1 FROM ma_session WHERE tenant_id = ? AND session_id = ? AND status <> 'DELETED'
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT harness_boot_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT o.claim_generation, o.claim_until AS lease_until, o.delivery_state, o.lifecycle_protocol_version, s.status, f.phase, f.operation_id FROM ma_operation o JOIN ma_session s ON s.tenant_id = o.tenant_id AND s.session_id = o.session_id JOIN ma_session_head f ON f.tenant_id = s.tenant_id AND f.harness_session_id = s.session_id WHERE o.operation_kind IN ('CLOSE', 'ARCHIVE', 'DELETE') AND o.tenant_id = ? AND o.session_id = ? AND o.operation_id = ? AND f.tenant_key = ? AND f.harness_key = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT o.lifecycle_protocol_version = 2 AND f.phase = 'DRAINING' FROM ma_operation o JOIN ma_session_head f ON f.tenant_id = o.tenant_id AND f.harness_session_id = o.session_id AND f.operation_id = o.operation_id WHERE o.operation_kind IN ('CLOSE', 'ARCHIVE', 'DELETE') AND o.tenant_id = ? AND o.session_id = ? AND o.operation_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT o.operation_id FROM ma_operation o JOIN ma_session s ON s.tenant_id = o.tenant_id AND s.session_id = o.session_id JOIN ma_session_head f ON f.tenant_id = o.tenant_id AND f.harness_session_id = o.session_id WHERE o.tenant_id = ? AND o.session_id = ? AND o.operation_kind = 'CLOSE' AND o.lifecycle_protocol_version = 0 AND o.delivery_state = 'LEASED' AND o.claim_until > ? AND s.status = 'CLOSING' AND f.tenant_key = ? AND f.harness_key = ? AND f.phase = 'DRAINING' AND f.operation_id IS NULL FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT tenant_id, session_id, compacted_through_revision, journal_revision FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND head_kind = 'MANAGED_SESSION' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT tool_profile FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|SELECT workspace_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|THEN 1 ELSE 0 END AS live_writer FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND head_kind = 'MANAGED_SESSION' FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/WorkspaceLifecycleStore.java|UPDATE ma_session_head SET gmt_modified =
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationAdmission.java|SELECT tenant_id, session_id, workspace_id FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationAdmission.java|SELECT tenant_id, session_id, workspace_storage_id FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationStore.java|FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationStore.java|SELECT COUNT(*) FROM ma_session s JOIN ma_operation o ON o.session_scope_key = s.session_scope_key AND o.tenant_id = s.tenant_id AND o.session_id = s.session_id WHERE s.tenant_id = ? AND s.workspace_storage_id = ? AND o.operation_kind IN ('CLOSE', 'ARCHIVE', 'DELETE', 'ACTION_RESPONSE', 'CWD_CHANGE', 'TASK_CANCEL') AND o.state NOT IN ('COMPLETED', 'FAILED')
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationStore.java|SELECT COUNT(*) FROM ma_session s JOIN ma_operation r ON r.session_scope_key = s.session_scope_key AND r.tenant_id = s.tenant_id AND r.session_id = s.session_id WHERE s.tenant_id = ? AND s.workspace_storage_id = ? AND r.operation_kind = 'RENAME' AND r.state IN ('PENDING', 'RUNNING', 'RECOVERY_BLOCKED')
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationStore.java|SELECT COUNT(*) FROM ma_session s JOIN ma_request_receipt c ON c.tenant_id = s.tenant_id AND c.session_id = s.session_id WHERE s.tenant_id = ? AND s.workspace_storage_id = ? AND c.namespace = 'SESSION_COMMAND' AND c.state = 'PENDING'
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationStore.java|SELECT COUNT(*) FROM ma_session s JOIN ma_session_head h ON h.tenant_key = s.tenant_key AND h.harness_key = s.session_key AND h.tenant_id = s.tenant_id AND h.session_id = s.session_id WHERE s.tenant_id = ? AND s.workspace_storage_id = ? AND h.state = 'ACTIVE' AND (h.writer_lease_until IS NULL OR h.writer_lease_until >
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationStore.java|SELECT COUNT(*) FROM ma_session s JOIN ma_turn t ON t.tenant_id = s.tenant_id AND t.session_id = s.session_id WHERE s.tenant_id = ? AND s.workspace_storage_id = ? AND t.status IN ('ACCEPTED', 'RUNNING', 'CANCELLING')
com/alibaba/qwen/code/managedagent/persistence/WorkspaceMigrationStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND workspace_storage_id = ? AND session_id > ? ORDER BY session_id LIMIT 32
com/alibaba/qwen/code/managedagent/persistence/WorkspaceOperatorRecoveryStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/managedagent/persistence/WorkspaceRecoveryStore.java|, e.last_sequence FROM ma_session s JOIN ma_event_stream e ON e.tenant_id = s.tenant_id AND e.session_id = s.session_id AND e.stream_kind = 'SESSION' AND e.stream_id = ? WHERE s.tenant_id = ? AND s.session_id = ? AND s.workspace_storage_id = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceRecoveryStore.java|FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/managedagent/persistence/WorkspaceRecoveryStore.java|SELECT COUNT(*) FROM ma_session_head WHERE tenant_key = ? AND harness_key = ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceRecoveryStore.java|SELECT COUNT(*) FROM ma_turn WHERE tenant_id = ? AND session_id = ? AND status IN ('ACCEPTED', 'RUNNING', 'CANCELLING')
com/alibaba/qwen/code/managedagent/persistence/WorkspaceRecoveryStore.java|SELECT session_id FROM ma_session WHERE tenant_id = ? AND workspace_storage_id = ? AND session_id > ? ORDER BY session_id LIMIT ?
com/alibaba/qwen/code/managedagent/persistence/WorkspaceRecoveryStore.java|SELECT tenant_id, session_id, retirement_operation_id AS operation_id, retirement_generation AS generation, retired_at, is_recovery_protected FROM ma_session WHERE tenant_id = ? AND session_id = ? AND retirement_generation > 0
com/alibaba/qwen/code/managedagent/persistence/evidence/CancelEvidence.java|SELECT t.turn_id, t.prompt_id, o.target_key FROM ma_operation o LEFT JOIN ma_turn t ON t.tenant_id = o.tenant_id AND t.session_id = o.session_id AND t.turn_id = o.target_id WHERE o.scope_key = ? AND o.tenant_id = ? AND o.session_id = ? AND o.operation_id = ? AND o.operation_kind = 'CANCEL' AND o.target_kind = 'TURN' AND o.state = 'RECOVERY_BLOCKED' AND o.delivery_state = 'BLOCKED' AND o.claim_owner IS NULL
com/alibaba/qwen/code/managedagent/persistence/evidence/CancelEvidence.java|SELECT workspace_id, journal_revision FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiActivationAdmission.java|FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_id = ? AND session_id = ? AND tenant_key = ? AND harness_key = ? AND harness_session_id = ? FOR UPDATE
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiActivationAdmission.java|SELECT * FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiActivationAdmission.java|SELECT latest_checkpoint_resource_id, harness_session_id FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiApplicationRetirement.java|SELECT workspace_id, state, activation_phase FROM ma_session_head WHERE head_kind = 'MANAGED_SESSION' AND tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiExecutionAdmission.java|SELECT journal_revision FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? AND tenant_id = ? AND session_id = ? AND head_kind = 'MANAGED_SESSION'
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiExecutionAdmission.java|SELECT s.tenant_id, s.workspace_id, s.workspace_generation, s.workspace_storage_id, s.cwd_relative, s.context_config_ref, s.context_revision, b.resource_handle_version, b.resource_handle_json FROM ma_session s JOIN ma_runtime_binding b ON b.binding_id = ? WHERE s.tenant_id = ? AND s.session_id = ?
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiFilesRetirementGuard.java|SELECT is_csi_guard FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiFilesRetirementGuard.java|SELECT tenant_id, session_id, agent_id, tool_profile, runtime_request_key, workspace_id, workspace_generation, workspace_storage_id, cwd_relative, context_config_ref, context_revision, workspace_config_ref, workspace_policy_ref FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
com/alibaba/qwen/code/runtimebroker/persistence/JdbcCsiFilesRetirementGuard.java|ma_session
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|INSERT INTO ma_session_head (tenant_key, harness_key, tenant_id, harness_session_id, session_id, head_kind, phase, gmt_create, gmt_modified) VALUES (?, ?, ?, ?, ?, 'HARNESS', 'DRAINING',
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|INSERT INTO ma_session_head (tenant_key, harness_key, tenant_id, harness_session_id, session_id, head_kind, phase, operation_id, gmt_create, gmt_modified) VALUES (?, ?, ?, ?, ?, 'HARNESS', 'LIFECYCLE_ONLY', ?,
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|SELECT o.lifecycle_protocol_version FROM ma_session_head f JOIN ma_operation o ON o.operation_kind IN ('CLOSE', 'ARCHIVE', 'DELETE') AND o.tenant_id = f.tenant_id AND o.session_id = f.harness_session_id AND o.operation_id = f.operation_id WHERE f.tenant_key = ? AND f.harness_key = ?
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|SELECT operation_id FROM ma_session_head WHERE tenant_key = ? AND harness_key = ?
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|SELECT phase FROM ma_session_head WHERE tenant_key = ? AND harness_key = ?
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|SELECT status, workspace_id, workspace_generation, context_config_ref, tool_profile FROM ma_session WHERE tenant_id = ? AND session_id = ?
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|SELECT tenant_id, harness_session_id, phase FROM ma_session_head WHERE tenant_key = ? AND harness_key = ?
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|SELECT tenant_id, harness_session_id, phase FROM ma_session_head WHERE tenant_key = ? AND harness_key = ? FOR UPDATE
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeBindingRepository.java|SELECT tenant_id, harness_session_id, phase, operation_id, claim_generation, claim_lease_until FROM ma_session_head WHERE tenant_key = ? AND harness_key = ?
com/alibaba/qwen/code/runtimebroker/persistence/JdbcRuntimeSessionRepository.java|SELECT * FROM ma_session WHERE tenant_id = ? AND session_id = ? FOR UPDATE
