diff --git a/agent/robot/manager/integration_clock_test.go b/agent/robot/manager/integration_clock_test.go index 68bd7ed1..d1e8d1ab 100644 --- a/agent/robot/manager/integration_clock_test.go +++ b/agent/robot/manager/integration_clock_test.go @@ -52,6 +52,10 @@ func TestIntegrationClockTimesMode(t *testing.T) { require.NoError(t, err) defer m.Stop() + // Verify robot is loaded into cache + robot := m.Cache().Get("robot_integ_clock_times1") + require.NotNil(t, robot, "Robot should be loaded into cache") + m.Executor().Reset() // Trigger at 09:00 on Wednesday diff --git a/agent/robot/manager/integration_concurrent_test.go b/agent/robot/manager/integration_concurrent_test.go index 9d0786e1..8c1933f0 100644 --- a/agent/robot/manager/integration_concurrent_test.go +++ b/agent/robot/manager/integration_concurrent_test.go @@ -76,6 +76,13 @@ func TestIntegrationConcurrentExecution(t *testing.T) { require.NoError(t, err) defer m.Stop() + // Verify robots are loaded into cache + for i := 0; i < 5; i++ { + memberID := "robot_integ_conc_multi_" + string(rune('A'+i)) + robot := m.Cache().Get(memberID) + require.NotNil(t, robot, "Robot %s should be loaded into cache", memberID) + } + ctx := types.NewContext(context.Background(), nil) // Trigger all robots simultaneously diff --git a/agent/robot/manager/integration_control_test.go b/agent/robot/manager/integration_control_test.go index 57649d61..31e1dc17 100644 --- a/agent/robot/manager/integration_control_test.go +++ b/agent/robot/manager/integration_control_test.go @@ -53,6 +53,10 @@ func TestIntegrationExecutionPauseResume(t *testing.T) { require.NoError(t, err) defer m.Stop() + // Verify robot is loaded into cache + robot := m.Cache().Get("robot_integ_ctrl_pause") + require.NotNil(t, robot, "Robot should be loaded into cache") + ctx := types.NewContext(context.Background(), nil) // Trigger execution diff --git a/agent/robot/manager/integration_event_test.go b/agent/robot/manager/integration_event_test.go index 754d25e0..d6de99e0 100644 --- a/agent/robot/manager/integration_event_test.go +++ b/agent/robot/manager/integration_event_test.go @@ -46,6 +46,10 @@ func TestIntegrationEventTrigger(t *testing.T) { require.NoError(t, err) defer m.Stop() + // Verify robot is loaded into cache + robot := m.Cache().Get("robot_integ_event_webhook") + require.NotNil(t, robot, "Robot should be loaded into cache") + ctx := types.NewContext(context.Background(), nil) req := &types.EventRequest{ MemberID: "robot_integ_event_webhook", diff --git a/agent/robot/manager/integration_human_test.go b/agent/robot/manager/integration_human_test.go index af4beac5..d408ecdb 100644 --- a/agent/robot/manager/integration_human_test.go +++ b/agent/robot/manager/integration_human_test.go @@ -47,6 +47,10 @@ func TestIntegrationHumanIntervention(t *testing.T) { require.NoError(t, err) defer m.Stop() + // Verify robot is loaded into cache + robot := m.Cache().Get("robot_integ_human_add") + require.NotNil(t, robot, "Robot should be loaded into cache") + ctx := types.NewContext(context.Background(), nil) req := &types.InterveneRequest{ TeamID: "team_integ_human",