#1899: [neon-cluster-operator]: MinWorkerNodeVcpuJob shouldn't be dis…

…abled
nforgeio · Apr 18, 2024 · 02b256e · 02b256e
1 parent 70c5d15
commit 02b256e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 8 deletions.
diff --git a/Services/neon-cluster-operator/Controllers/NeonJobController.cs b/Services/neon-cluster-operator/Controllers/NeonJobController.cs
@@ -146,16 +146,10 @@ public override async Task<ResourceControllerResult> ReconcileAsync(V1NeonCluste
                 // The [workerNodeVcpuScheduleJob] uses a hardcoded schedule (1:30am UTC) rather than picking up its
                 // schedule from the [V1NeonClusterJobs] resource.
 
-                // $todo(jefflill): figure out why this is broken and causes the controller to barf when reconciling.
-                //
-                //      https://github.com/nforgeio/neonKUBE/issues/1899
-
-#if TODO
                 await ScheduleJobAsync<MinWorkerNodeVcpuJob>(
                     scheduler,
                     k8s,
-                    "0 30 1 ? * *");
-#endif
+                    0 30 1 ? **");  // 1:30am UTC
 
                 // We're going to accumulate any patches to the job status with the
                 // original and resolved CRON schedules.

diff --git a/Services/neon-cluster-operator/CronJobs/MinWorkerNodeVcpuJob.cs b/Services/neon-cluster-operator/CronJobs/MinWorkerNodeVcpuJob.cs
@@ -120,7 +120,7 @@ public async Task Execute(IJobExecutionContext context)
 
                     do
                     {
-                        var nodes = await k8s.CoreV1.ListNodeAsync(continueParameter: continueToken, limit: 10);
+                        var nodes = await k8s.CoreV1.ListNodeAsync(continueParameter: continueToken);
 
                         continueToken = nodes.Continue();
-Original file line number
+Diff line change
@@ Expand Up / @@ -120,7 +120,7 @@ public async Task Execute(IJobExecutionContext context) @@
                         do
                         {
-                            var nodes = await k8s.CoreV1.ListNodeAsync(continueParameter: continueToken, limit: 10);
+                            var nodes = await k8s.CoreV1.ListNodeAsync(continueParameter: continueToken);
                             continueToken = nodes.Continue();
@@ Expand Down @@