@@ -99,7 +99,10 @@ class ManagedSupervisor {
99
99
this . logger . warn ( "[ManagedWorker] Failed pod handler disabled" ) ;
100
100
}
101
101
102
- this . resourceMonitor = new KubernetesResourceMonitor ( createK8sApi ( ) , "" ) ;
102
+ this . resourceMonitor = new KubernetesResourceMonitor (
103
+ createK8sApi ( ) ,
104
+ env . TRIGGER_WORKER_INSTANCE_NAME
105
+ ) ;
103
106
this . workloadManager = new KubernetesWorkloadManager ( workloadManagerOptions ) ;
104
107
} else {
105
108
this . resourceMonitor = new DockerResourceMonitor ( new Docker ( ) ) ;
@@ -117,7 +120,7 @@ class ManagedSupervisor {
117
120
runNotificationsEnabled : env . TRIGGER_WORKLOAD_API_ENABLED ,
118
121
preDequeue : async ( ) => {
119
122
if ( this . isKubernetes ) {
120
- // TODO: Test k8s resource monitor and remove this
123
+ // Not used in k8s for now
121
124
return { } ;
122
125
}
123
126
@@ -235,10 +238,11 @@ class ManagedSupervisor {
235
238
snapshotFriendlyId : message . snapshot . friendlyId ,
236
239
} ) ;
237
240
238
- this . resourceMonitor . blockResources ( {
239
- cpu : message . run . machine . cpu ,
240
- memory : message . run . machine . memory ,
241
- } ) ;
241
+ // Disabled for now
242
+ // this.resourceMonitor.blockResources({
243
+ // cpu: message.run.machine.cpu,
244
+ // memory: message.run.machine.memory,
245
+ // });
242
246
} catch ( error ) {
243
247
this . logger . error ( "[ManagedWorker] Failed to create workload" , { error } ) ;
244
248
}
0 commit comments