Support namespace per org for Kubernetes step secrets (#5383)

Co-authored-by: Robert Kaussow <mail@thegeeklab.de>
This commit is contained in:
Harri Avellan 2025-08-05 10:27:18 +03:00 committed by GitHub
parent 966c417286
commit e9ab04f88b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -319,7 +319,7 @@ func startStepSecret(ctx context.Context, e *kube, step *types.Step) error {
return err
}
log.Trace().Msgf("creating secret: %s", secret.Name)
_, err = e.client.CoreV1().Secrets(e.config.Namespace).Create(ctx, secret, meta_v1.CreateOptions{})
_, err = e.client.CoreV1().Secrets(e.config.GetNamespace(step.OrgID)).Create(ctx, secret, meta_v1.CreateOptions{})
if err != nil {
return err
}
@ -334,7 +334,7 @@ func mkStepSecret(step *types.Step, config *config) (*v1.Secret, error) {
return &v1.Secret{
ObjectMeta: meta_v1.ObjectMeta{
Namespace: config.Namespace,
Namespace: config.GetNamespace(step.OrgID),
Name: name,
},
Type: v1.SecretTypeOpaque,
@ -357,7 +357,7 @@ func stopStepSecret(ctx context.Context, engine *kube, step *types.Step, deleteO
}
log.Trace().Str("name", name).Msg("deleting secret")
err = engine.client.CoreV1().Secrets(engine.config.Namespace).Delete(ctx, name, deleteOpts)
err = engine.client.CoreV1().Secrets(engine.config.GetNamespace(step.OrgID)).Delete(ctx, name, deleteOpts)
if errors.IsNotFound(err) {
return nil
}