Function TestDetectorNoHungJobs

coderd/jobreaper/detector_test.go:116–150

(t *testing.T)

}

func TestDetectorNoHungJobs(t *testing.T) {
	t.Parallel()

	ctx := testutil.Context(t, testutil.WaitLong)
	env := newDetectorTestEnv(ctx, t)
	defer env.close()

	// Insert some jobs that are running and haven't been updated in a while,
	// but not enough to be considered hung.
	now := time.Now()
	org := dbgen.Organization(t, env.DB, database.Organization{})
	user := dbgen.User(t, env.DB, database.User{})
	file := dbgen.File(t, env.DB, database.File{})
	for i := 0; i < 5; i++ {
		dbgen.ProvisionerJob(t, env.DB, env.Pubsub, database.ProvisionerJob{
			CreatedAt: now.Add(-time.Minute * 5),
			UpdatedAt: now.Add(-time.Minute * time.Duration(i)),
			StartedAt: sql.NullTime{
				Time:  now.Add(-time.Minute * 5),
				Valid: true,
			},
			OrganizationID: org.ID,
			InitiatorID:    user.ID,
			Provisioner:    database.ProvisionerTypeEcho,
			StorageMethod:  database.ProvisionerStorageMethodFile,
			FileID:         file.ID,
			Type:           database.ProvisionerJobTypeWorkspaceBuild,
			Input:          []byte("{}"),
		})
	}

	stats := env.tick(ctx, now)
	require.NoError(t, stats.Error)
	require.Empty(t, stats.TerminatedJobIDs)
}

func TestDetectorHungWorkspaceBuild(t *testing.T) {
	t.Parallel()