Skip to content

Commit

Permalink
DEVPROD-13862 remove commit queue collection (#8639)
Browse files Browse the repository at this point in the history
  • Loading branch information
ablack12 authored Jan 21, 2025
1 parent efd1901 commit e69618c
Show file tree
Hide file tree
Showing 42 changed files with 78 additions and 1,306 deletions.
1 change: 0 additions & 1 deletion config_db.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,6 @@ var (
cacheStatsJobDisabledKey = bsonutil.MustHaveTag(ServiceFlags{}, "CacheStatsJobDisabled")
cacheStatsEndpointDisabledKey = bsonutil.MustHaveTag(ServiceFlags{}, "CacheStatsEndpointDisabled")
taskReliabilityDisabledKey = bsonutil.MustHaveTag(ServiceFlags{}, "TaskReliabilityDisabled")
commitQueueDisabledKey = bsonutil.MustHaveTag(ServiceFlags{}, "CommitQueueDisabled")
hostAllocatorDisabledKey = bsonutil.MustHaveTag(ServiceFlags{}, "HostAllocatorDisabled")
podAllocatorDisabledKey = bsonutil.MustHaveTag(ServiceFlags{}, "PodAllocatorDisabled")
backgroundReauthDisabledKey = bsonutil.MustHaveTag(ServiceFlags{}, "BackgroundReauthDisabled")
Expand Down
2 changes: 0 additions & 2 deletions config_serviceflags.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ type ServiceFlags struct {
CacheStatsJobDisabled bool `bson:"cache_stats_job_disabled" json:"cache_stats_job_disabled"`
CacheStatsEndpointDisabled bool `bson:"cache_stats_endpoint_disabled" json:"cache_stats_endpoint_disabled"`
TaskReliabilityDisabled bool `bson:"task_reliability_disabled" json:"task_reliability_disabled"`
CommitQueueDisabled bool `bson:"commit_queue_disabled" json:"commit_queue_disabled"`
HostAllocatorDisabled bool `bson:"host_allocator_disabled" json:"host_allocator_disabled"`
PodAllocatorDisabled bool `bson:"pod_allocator_disabled" json:"pod_allocator_disabled"`
UnrecognizedPodCleanupDisabled bool `bson:"unrecognized_pod_cleanup_disabled" json:"unrecognized_pod_cleanup_disabled"`
Expand Down Expand Up @@ -80,7 +79,6 @@ func (c *ServiceFlags) Set(ctx context.Context) error {
cacheStatsJobDisabledKey: c.CacheStatsJobDisabled,
cacheStatsEndpointDisabledKey: c.CacheStatsEndpointDisabled,
taskReliabilityDisabledKey: c.TaskReliabilityDisabled,
commitQueueDisabledKey: c.CommitQueueDisabled,
hostAllocatorDisabledKey: c.HostAllocatorDisabled,
podAllocatorDisabledKey: c.PodAllocatorDisabled,
backgroundCleanupDisabledKey: c.BackgroundCleanupDisabled,
Expand Down
4 changes: 0 additions & 4 deletions globals.go
Original file line number Diff line number Diff line change
Expand Up @@ -329,10 +329,6 @@ const (
GithubChecksAlias = "__github_checks"
GitTagAlias = "__git_tag"

MergeTaskVariant = "commit-queue-merge"
MergeTaskName = "merge-patch"
MergeTaskGroup = "merge-task-group"

DefaultJasperPort = 2385

GithubAppPrivateKey = "github_app_key"
Expand Down
19 changes: 0 additions & 19 deletions graphql/integration_atomic_test_util.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@ import (
"github.com/evergreen-ci/evergreen/db"
"github.com/evergreen-ci/evergreen/model"
"github.com/evergreen-ci/evergreen/model/build"
"github.com/evergreen-ci/evergreen/model/commitqueue"
"github.com/evergreen-ci/evergreen/model/distro"
"github.com/evergreen-ci/evergreen/model/host"
"github.com/evergreen-ci/evergreen/model/log"
Expand Down Expand Up @@ -149,7 +148,6 @@ func MakeTestsInDirectory(state *AtomicGraphQLState, pathToTests string) func(t
grip.Info("=== actual ===")
grip.Info(actual.Bytes())
}
additionalChecks(t)
}

t.Run(testCase.QueryFile, singleTest)
Expand Down Expand Up @@ -690,20 +688,3 @@ func addSubnets(t *testing.T) {
func clearSubnets(t *testing.T) {
evergreen.GetEnvironment().Settings().Providers.AWS.Subnets = []evergreen.Subnet{}
}

func additionalChecks(t *testing.T) {
var checks = map[string]func(*testing.T){
// note these 2 are only the same because the same project ID is used
"TestAtomicGQLQueries/abortTask/commit-queue-dequeue.graphql": checkCommitQueueDequeued,
"TestAtomicGQLQueries/unschedulePatchTasks/commit-queue-dequeue.graphql": checkCommitQueueDequeued,
}
if check, exists := checks[t.Name()]; exists {
check(t)
}
}

func checkCommitQueueDequeued(t *testing.T) {
cq, err := commitqueue.FindOneId("p1")
assert.NoError(t, err)
assert.Empty(t, cq.Queue)
}
206 changes: 0 additions & 206 deletions model/commitqueue/commit_queue.go

This file was deleted.

Loading

0 comments on commit e69618c

Please sign in to comment.