@@ -10,6 +10,7 @@ import (
1010	"fmt" 
1111	"strings" 
1212
13+ 	"github.com/go-logr/zerologr" 
1314	"github.com/hypermodeinc/modus/lib/manifest" 
1415	"github.com/hypermodeinc/modus/runtime/app" 
1516	"github.com/hypermodeinc/modus/runtime/logger" 
@@ -52,7 +53,7 @@ func (sp *kubernetesSecretsProvider) initialize(ctx context.Context) {
5253	sp .secretNamespace  =  parts [0 ]
5354	sp .secretName  =  parts [1 ]
5455
55- 	cli , cache , err  :=  newK8sClientForSecret (sp .secretNamespace , sp .secretName )
56+ 	cli , cache , err  :=  newK8sClientForSecret (ctx ,  sp .secretNamespace , sp .secretName )
5657	if  err  !=  nil  {
5758		const  msg  =  "Failed to initialize Kubernetes client." 
5859		sentryutils .CaptureError (ctx , err , msg ,
@@ -157,12 +158,14 @@ func (sp *kubernetesSecretsProvider) hasSecret(ctx context.Context, name string)
157158
158159// newK8sClientForSecret creates a new Kubernetes client that watches 
159160// only a single secret `name` in namespace `ns`. 
160- func  newK8sClientForSecret (ns , name  string ) (client.Client , pkgcache.Cache , error ) {
161+ func  newK8sClientForSecret (ctx  context. Context ,  ns , name  string ) (client.Client , pkgcache.Cache , error ) {
161162	scheme  :=  runtime .NewScheme ()
162163	if  err  :=  clientgoscheme .AddToScheme (scheme ); err  !=  nil  {
163164		return  nil , nil , err 
164165	}
165166
167+ 	ctrl .SetLogger (zerologr .New (logger .Get (ctx )))
168+ 
166169	cl , err  :=  cluster .New (ctrl .GetConfigOrDie (), func (clusterOptions  * cluster.Options ) {
167170		clusterOptions .Scheme  =  scheme 
168171		clusterOptions .Cache .DefaultNamespaces  =  make (map [string ]pkgcache.Config )
0 commit comments