Method TestMissedWebhookRecovery

runner/pool/pool_test.go:413–448

TestMissedWebhookRecovery simulates a job that was queued while GARM was offline.

()

// TestMissedWebhookRecovery simulates a job that was queued while GARM was offline.
func (s *PoolStressTestSuite) TestMissedWebhookRecovery() {
	s.setupProviderMocks()

	labels := []string{"self-hosted", "linux", "x64"}

	// Directly insert a queued job into the DB (simulating a job we received but
	// the runner was never created because GARM was restarted).
	job := params.Job{
		WorkflowJobID:   4001,
		Action:          "queued",
		Status:          "queued",
		Labels:          labels,
		RepositoryName:  "test-repo",
		RepositoryOwner: "test-owner",
		RepoID:          garmTesting.Ptr(mustParseUUID(s.entity.ID)),
	}
	_, err := s.store.CreateOrUpdateJob(s.adminCtx, job)
	s.Require().NoError(err)

	// Populate the in-memory jobs map
	s.syncJobsFromDB()

	// consumeQueuedJobs should create a runner for this orphaned job
	err = s.mgr.consumeQueuedJobs()
	s.Require().NoError(err)

	instances, err := s.store.ListPoolInstances(s.adminCtx, s.pool.ID, false)
	s.Require().NoError(err)
	s.NotEmpty(instances, "expected a runner to be created for the missed job")

	// Verify DB: the orphaned job should still be queued but locked.
	queuedJobs, err := s.store.ListJobsByStatus(s.adminCtx, params.JobStatusQueued)
	s.Require().NoError(err)
	s.Len(queuedJobs, 1, "exactly 1 queued job should exist")
	s.NotEqual(uuid.UUID{}, queuedJobs[0].LockedBy, "job should be locked after consume")
}

// TestConsumeQueuedJobsRespectsBackoff verifies the JobBackoff fix.
func (s *PoolStressTestSuite) TestConsumeQueuedJobsRespectsBackoff() {