fix: update tests for reduced executor set

Replace system_info_executor references with aggregate_results_executor
in tests that just need a working executor (hooks, reexecution, session pool).
Delete v1 integration test for system resource aggregation.

887 passed, 0 failures.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: tercel

tests/core/execution/test_task_manager.py

@@ -63,7 +63,7 @@ async def post_hook(task, inputs, result):
             name="Test Task",
             user_id="test-user",
             inputs={"resource": "cpu"},
-            schemas={"method": "rest_executor"},
+            schemas={"method": "aggregate_results_executor"},
         )
 
         # Create a simple task tree
@@ -104,7 +104,7 @@ def sync_post_hook(task, inputs, result):
             name="Test Task",
             user_id="test-user",
             inputs={"resource": "cpu"},
-            schemas={"method": "rest_executor"},
+            schemas={"method": "aggregate_results_executor"},
         )
 
         task_tree = TaskTreeNode(task)
@@ -137,7 +137,7 @@ async def failing_post_hook(task, inputs, result):
             name="Test Task",
             user_id="test-user",
             inputs={"resource": "cpu"},
-            schemas={"method": "rest_executor"},
+            schemas={"method": "aggregate_results_executor"},
         )
 
         task_tree = TaskTreeNode(task)

tests/core/execution/test_task_reexecution.py

@@ -28,7 +28,7 @@ async def test_reexecute_failed_task(self, use_test_db_session):
             status="pending",
             priority=1,
             inputs={"resource": "cpu"},
-            schemas={"method": "rest_executor"},
+            schemas={"method": "aggregate_results_executor"},
         )
 
         # Execute the task first time - should succeed
@@ -76,7 +76,7 @@ async def test_reexecute_failed_task_with_dependencies(self, use_test_db_session
             status="pending",
             priority=1,
             inputs={"resource": "cpu"},
-            schemas={"method": "rest_executor"},
+            schemas={"method": "aggregate_results_executor"},
         )
 
         # Create parent task that depends on child
@@ -167,7 +167,7 @@ async def test_pending_tasks_not_marked_for_reexecution(self, use_test_db_sessio
             status="pending",
             priority=1,
             inputs={"resource": "cpu"},
-            schemas={"method": "rest_executor"},
+            schemas={"method": "aggregate_results_executor"},
         )
 
         # Execute the task - should execute normally (not as re-execution)
@@ -195,7 +195,7 @@ async def test_completed_tasks_skipped_unless_dependency(self, use_test_db_sessi
             status="pending",
             priority=1,
             inputs={"resource": "cpu"},
-            schemas={"method": "rest_executor"},
+            schemas={"method": "aggregate_results_executor"},
         )
 
         # Execute the task first time

tests/core/storage/sqlalchemy/test_session_pool.py

@@ -319,7 +319,7 @@ async def test_task_executor_with_task_tree_session(self, tmp_path):
                 name="Root Task",
                 status="pending",
                 user_id="test-user",
-                schemas={"method": "system_info_executor"},
+                schemas={"method": "aggregate_results_executor"},
                 inputs={"resource": "cpu"},
             )
             session.commit()
@@ -365,7 +365,7 @@ async def test_concurrent_task_tree_execution(self, tmp_path):
                     name=f"Root Task {i}",
                     status="pending",
                     user_id="test-user",
-                    schemas={"method": "system_info_executor"},
+                    schemas={"method": "aggregate_results_executor"},
                     inputs={"resource": "cpu"},
                 )
             session.commit()
@@ -467,7 +467,7 @@ async def test_concurrent_execution_with_session_limit(self, tmp_path, monkeypat
                     name=f"Root Task {i}",
                     status="pending",
                     user_id="test-user",
-                    schemas={"method": "system_info_executor"},
+                    schemas={"method": "aggregate_results_executor"},
                     inputs={"resource": "cpu"},
                 )
             session.commit()
@@ -537,7 +537,7 @@ async def test_concurrent_execution_no_data_conflicts(self, tmp_path):
                     name=f"Root Task {i}",
                     status="pending",
                     user_id=f"user-{i}",
-                    schemas={"method": "system_info_executor"},
+                    schemas={"method": "aggregate_results_executor"},
                     inputs={"resource": "cpu"},
                 )
             session.commit()
@@ -599,7 +599,7 @@ async def test_session_cleanup_after_execution(self, tmp_path):
                 name="Root Task",
                 status="pending",
                 user_id="test-user",
-                schemas={"method": "system_info_executor"},
+                schemas={"method": "aggregate_results_executor"},
                 inputs={"resource": "cpu"},
             )
             session.commit()

tests/core/storage/test_hook_modify_task_with_context.py

@@ -160,7 +160,7 @@ async def modify_after_execution_hook(task, inputs, result):
         task = await repo.create_task(
             name="Test Task",
             user_id="test-user",
-            params={"resource": "cpu", "executor_id": "rest_executor"},
+            params={"resource": "cpu", "executor_id": "aggregate_results_executor"},
         )
         task_id = task.id