Skip to content

Commit

Permalink
Merge branch 'master' into scheduler-metrics-cont
Browse files Browse the repository at this point in the history
  • Loading branch information
severinson authored Sep 6, 2023
2 parents 888f975 + bd08722 commit 7987a66
Show file tree
Hide file tree
Showing 48 changed files with 2,004 additions and 1,044 deletions.
2 changes: 0 additions & 2 deletions .github/workflows/ci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,6 @@ permissions:
jobs:
lint:
uses: ./.github/workflows/lint.yml
codeql:
uses: ./.github/workflows/codeql-analysis.yml
test:
uses: ./.github/workflows/test.yml
# Virtual job that can be configured as a required check before a PR can be merged.
Expand Down
3 changes: 2 additions & 1 deletion .github/workflows/codeql-analysis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,8 @@
name: "CodeQL"

on:
workflow_call:
schedule:
- cron: "0 9 * * *"

permissions:
actions: read
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
<ItemGroup>
<PackageReference Include="Google.Protobuf" Version="3.21.1" />
<PackageReference Include="Grpc.Tools" Version="2.47.0" />
<PackageReference Include="Grpc.Net.Client" Version="2.47.0" />
<PackageReference Include="Grpc.Net.Client" Version="2.52.0" />
</ItemGroup>

<ItemGroup>
Expand Down
10 changes: 7 additions & 3 deletions cmd/executor/main.go
Original file line number Diff line number Diff line change
@@ -1,12 +1,14 @@
package main

import (
"context"
"net/http"
"os"
"os/signal"
"syscall"

"github.com/prometheus/client_golang/prometheus"
"github.com/sirupsen/logrus"
"github.com/spf13/pflag"
"github.com/spf13/viper"

Expand Down Expand Up @@ -47,11 +49,13 @@ func main() {
shutdownChannel := make(chan os.Signal, 1)
signal.Notify(shutdownChannel, syscall.SIGINT, syscall.SIGTERM)

shutdownMetricServer := common.ServeMetricsFor(config.Metric.Port,
prometheus.Gatherers{metrics.GetMetricsGatherer()})
shutdownMetricServer := common.ServeMetricsFor(
config.Metric.Port,
prometheus.Gatherers{metrics.GetMetricsGatherer()},
)
defer shutdownMetricServer()

shutdown, wg := executor.StartUp(config)
shutdown, wg := executor.StartUp(context.Background(), logrus.NewEntry(logrus.New()), config)
go func() {
<-shutdownChannel
shutdown()
Expand Down
5 changes: 1 addition & 4 deletions config/executor/config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ application:
useExecutorApi: false
useLegacyApi: true
jobLeaseRequestTimeout: "30s"
maxLeasedJobs: 100
task:
utilisationReportingInterval: 1s
missingJobEventReconciliationInterval: 15s
Expand Down Expand Up @@ -36,10 +37,6 @@ kubernetes:
impersonateUsers: false
trackedNodeLabels:
- kubernetes.io/hostname
etcd:
fractionOfStorageInUseSoftLimit: 0.8
fractionOfStorageInUseHardLimit: 0.9
minimumAvailable: 2
QPS: 10000
Burst: 10000
nodeIdLabel: kubernetes.io/hostname
Expand Down
3 changes: 3 additions & 0 deletions deployment/executor/templates/deployment.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,9 @@ spec:
{{- end }}
nodeSelector:
{{- toYaml .Values.nodeSelector | nindent 8 }}
{{- if .Values.priorityClassName }}
priorityClassName: {{- .Values.priorityClassName }}
{{- end }}
tolerations:
{{- toYaml .Values.tolerations | nindent 8 }}
volumes:
Expand Down
1 change: 1 addition & 0 deletions deployment/executor/values.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ nodeSelector: {}
tolerations: []
customServiceAccount: null
serviceAccount: null
priorityClassName: ""

healthcheck:
enabled: false
Expand Down
65 changes: 34 additions & 31 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,11 @@ require (
github.com/go-openapi/analysis v0.21.4
github.com/go-openapi/jsonreference v0.20.2
github.com/go-openapi/loads v0.21.2
github.com/go-openapi/runtime v0.24.2
github.com/go-openapi/spec v0.20.7
github.com/go-openapi/runtime v0.26.0
github.com/go-openapi/spec v0.20.8
github.com/go-redis/redis v6.15.9+incompatible
github.com/gogo/protobuf v1.3.2
github.com/golang/protobuf v1.5.2
github.com/golang/protobuf v1.5.3
github.com/google/go-cmp v0.5.9
github.com/google/uuid v1.3.0
github.com/grpc-ecosystem/go-grpc-middleware v1.3.0
Expand All @@ -50,18 +50,18 @@ require (
github.com/rakyll/statik v0.1.7
github.com/renstrom/shortuuid v3.0.0+incompatible
github.com/sirupsen/logrus v1.9.0
github.com/spf13/cobra v1.6.1
github.com/spf13/cobra v1.7.0
github.com/spf13/pflag v1.0.5
github.com/spf13/viper v1.15.0
github.com/stretchr/testify v1.8.1
github.com/stretchr/testify v1.8.3
github.com/weaveworks/promrus v1.2.0
golang.org/x/exp v0.0.0-20221031165847-c99f073a8326
golang.org/x/net v0.7.0
golang.org/x/oauth2 v0.4.0
golang.org/x/sync v0.1.0
golang.org/x/tools v0.5.0 // indirect
google.golang.org/genproto v0.0.0-20221227171554-f9683d7f8bef
google.golang.org/grpc v1.52.0
golang.org/x/net v0.9.0
golang.org/x/oauth2 v0.7.0
golang.org/x/sync v0.3.0
golang.org/x/tools v0.6.0 // indirect
google.golang.org/genproto v0.0.0-20230526161137-0005af68ea54 // indirect
google.golang.org/grpc v1.57.0
gopkg.in/yaml.v2 v2.4.0
k8s.io/api v0.22.4
k8s.io/apimachinery v0.22.4
Expand All @@ -75,14 +75,14 @@ require (
)

require (
github.com/Masterminds/semver/v3 v3.2.0
github.com/Masterminds/semver/v3 v3.2.1
github.com/benbjohnson/immutable v0.4.3
github.com/caarlos0/log v0.2.1
github.com/go-openapi/errors v0.20.3
github.com/go-openapi/strfmt v0.21.3
github.com/go-openapi/strfmt v0.21.7
github.com/go-openapi/swag v0.22.3
github.com/go-openapi/validate v0.22.1
github.com/go-playground/validator/v10 v10.11.1
github.com/go-playground/validator/v10 v10.14.1
github.com/golang/mock v1.6.0
github.com/goreleaser/goreleaser v1.15.2
github.com/jackc/pgx/v5 v5.3.1
Expand All @@ -93,6 +93,7 @@ require (
github.com/prometheus/common v0.37.0
github.com/sanity-io/litter v1.5.5
github.com/segmentio/fasthash v1.0.3
google.golang.org/genproto/googleapis/api v0.0.0-20230525234035-dd9d682886f9
)

require (
Expand All @@ -103,12 +104,12 @@ require (
github.com/DataDog/zstd v1.5.0 // indirect
github.com/alicebob/gopher-json v0.0.0-20180125190556-5a6b3ba71ee6 // indirect
github.com/ardielle/ardielle-go v1.5.2 // indirect
github.com/asaskevich/govalidator v0.0.0-20210307081110-f21760c49a8d // indirect
github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2 // indirect
github.com/aymanbagabas/go-osc52 v1.2.1 // indirect
github.com/beorn7/perks v1.0.1 // indirect
github.com/bits-and-blooms/bitset v1.4.0 // indirect
github.com/blang/semver v3.5.1+incompatible // indirect
github.com/cespare/xxhash/v2 v2.1.2 // indirect
github.com/cespare/xxhash/v2 v2.2.0 // indirect
github.com/charmbracelet/lipgloss v0.6.1-0.20220911181249-6304a734e792 // indirect
github.com/danieljoos/wincred v1.1.2 // indirect
github.com/davecgh/go-spew v1.1.1 // indirect
Expand All @@ -118,11 +119,12 @@ require (
github.com/fatih/color v1.13.0 // indirect
github.com/fortytw2/leaktest v1.3.0 // indirect
github.com/fsnotify/fsnotify v1.6.0 // indirect
github.com/gabriel-vasile/mimetype v1.4.2 // indirect
github.com/go-asn1-ber/asn1-ber v1.5.4 // indirect
github.com/go-logr/logr v0.4.0 // indirect
github.com/go-logr/logr v1.2.3 // indirect
github.com/go-openapi/jsonpointer v0.19.6 // indirect
github.com/go-playground/locales v0.14.0 // indirect
github.com/go-playground/universal-translator v0.18.0 // indirect
github.com/go-playground/locales v0.14.1 // indirect
github.com/go-playground/universal-translator v0.18.1 // indirect
github.com/gobwas/glob v0.2.3 // indirect
github.com/godbus/dbus v0.0.0-20190726142602-4481cbc300e2 // indirect
github.com/golang-jwt/jwt v3.2.2+incompatible // indirect
Expand All @@ -131,15 +133,15 @@ require (
github.com/google/gofuzz v1.1.0 // indirect
github.com/googleapis/gnostic v0.5.5 // indirect
github.com/goreleaser/fileglob v1.3.0 // indirect
github.com/goreleaser/nfpm/v2 v2.25.1 // indirect
github.com/goreleaser/nfpm/v2 v2.29.0 // indirect
github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c // indirect
github.com/hashicorp/errwrap v1.1.0 // indirect
github.com/hashicorp/go-immutable-radix v1.3.1 // indirect
github.com/hashicorp/go-uuid v1.0.2 // indirect
github.com/hashicorp/hcl v1.0.0 // indirect
github.com/iancoleman/orderedmap v0.2.0 // indirect
github.com/imdario/mergo v0.3.13 // indirect
github.com/inconshreveable/mousetrap v1.0.1 // indirect
github.com/imdario/mergo v0.3.15 // indirect
github.com/inconshreveable/mousetrap v1.1.0 // indirect
github.com/invopop/jsonschema v0.7.0 // indirect
github.com/jackc/pgio v1.0.0 // indirect
github.com/jackc/pgpassfile v1.0.0 // indirect
Expand All @@ -153,8 +155,8 @@ require (
github.com/josharian/intern v1.0.0 // indirect
github.com/json-iterator/go v1.1.12 // indirect
github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 // indirect
github.com/klauspost/compress v1.15.15 // indirect
github.com/leodido/go-urn v1.2.1 // indirect
github.com/klauspost/compress v1.16.5 // indirect
github.com/leodido/go-urn v1.2.4 // indirect
github.com/linkedin/goavro/v2 v2.9.8 // indirect
github.com/lucasb-eyer/go-colorful v1.2.0 // indirect
github.com/magiconair/properties v1.8.7 // indirect
Expand Down Expand Up @@ -186,21 +188,22 @@ require (
github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415 // indirect
github.com/xeipuuv/gojsonschema v1.2.0 // indirect
github.com/yuin/gopher-lua v0.0.0-20190514113301-1cd887cd7036 // indirect
go.mongodb.org/mongo-driver v1.10.2 // indirect
go.mongodb.org/mongo-driver v1.11.3 // indirect
go.uber.org/atomic v1.9.0 // indirect
golang.org/x/crypto v0.6.0 // indirect
golang.org/x/mod v0.7.0 // indirect
golang.org/x/sys v0.5.0 // indirect
golang.org/x/term v0.5.0 // indirect
golang.org/x/text v0.7.0 // indirect
golang.org/x/crypto v0.7.0 // indirect
golang.org/x/mod v0.8.0 // indirect
golang.org/x/sys v0.7.0 // indirect
golang.org/x/term v0.7.0 // indirect
golang.org/x/text v0.9.0 // indirect
golang.org/x/time v0.3.0 // indirect
google.golang.org/appengine v1.6.7 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20230525234030-28d5490b6b19 // indirect
google.golang.org/protobuf v1.30.0 // indirect
gopkg.in/inf.v0 v0.9.1 // indirect
gopkg.in/ini.v1 v1.67.0 // indirect
gopkg.in/square/go-jose.v2 v2.6.0 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
k8s.io/klog/v2 v2.9.0 // indirect
k8s.io/klog/v2 v2.100.1 // indirect
k8s.io/kube-openapi v0.0.0-20211109043538-20434351676c // indirect
lukechampine.com/uint128 v1.2.0 // indirect
modernc.org/cc/v3 v3.40.0 // indirect
Expand Down
Loading

0 comments on commit 7987a66

Please sign in to comment.