Fix async job tests

monti-apm · Nov 23, 2024 · 098998a · 098998a
1 parent 572d715
commit 098998a
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/tests/models/jobs.js b/tests/models/jobs.js
@@ -57,9 +57,9 @@ Tinytest.add(
   }
 );
 
-Tinytest.addAsync(
+Tinytest.add(
   'Models - Jobs - track new jobs',
-  async function (test) {
+  function (test) {
     model.trackNewJob('analyze');
     model.trackNewJob('analyze');
     model.trackNewJob('analyze');
@@ -70,9 +70,9 @@ Tinytest.addAsync(
   }
 );
 
-Tinytest.addAsync(
+Tinytest.add(
   'Models - Jobs - track active jobs',
-  async function (test) {
+  function (test) {
     model.activeJobCounts.clear();
     model.trackActiveJobs('analyze', 1);
     model.trackActiveJobs('analyze', 1);
@@ -90,7 +90,7 @@ Tinytest.addAsync(
   }
 );
 
-Tinytest.addAsync(
+Tinytest.add(
   'Models - Jobs - Monti.recordNewJob',
   async function (test) {
     Kadira.recordNewJob('hello');
@@ -100,7 +100,7 @@ Tinytest.addAsync(
   }
 );
 
-Tinytest.addAsync(
+Tinytest.add(
   'Models - Jobs - Monti.recordPendingJobs',
   async function (test) {
     Kadira.recordPendingJobs('hello', 5);
@@ -126,17 +126,18 @@ Tinytest.add(
 
 Tinytest.addAsync(
   'Models - Jobs - traceJob - return async value',
-  async function (test) {
+  async function (test, done) {
     let result = await Kadira.traceJob({ name: 'hello' }, () => Promise.resolve(5));
 
     test.equal(result, 5);
     CleanTestData();
+    done();
   }
 );
 
-Tinytest.addAsync(
+Tinytest.add(
   'Models - Jobs - traceJob - track sync processor',
-  async function (test) {
+  function (test) {
     Kadira.traceJob({ name: 'hello' }, () => {
       TestData.find().fetch();
     });
@@ -151,7 +152,7 @@ Tinytest.addAsync(
 
 Tinytest.addAsync(
   'Models - Jobs - traceJob - track active status',
-  async function (test) {
+  async function (test, done) {
     model.activeJobCounts.clear();
 
     let resolver;
@@ -175,6 +176,7 @@ Tinytest.addAsync(
     test.equal(payload.jobMetrics[0].jobs.hello.count, 1);
 
     CleanTestData();
+    done();
   }
 );