From c7e402e71e494b445640a1ac1d847b186034ece4 Mon Sep 17 00:00:00 2001
From: Bogdan Fazakas <bogdan.fazakas@gmail.com>
Date: Tue, 23 Aug 2022 10:50:32 +0300
Subject: [PATCH] log job status each sec

---
 test/integration/ComputeFlow.test.ts | 38 +++++++++++++++-------------
 1 file changed, 20 insertions(+), 18 deletions(-)

diff --git a/test/integration/ComputeFlow.test.ts b/test/integration/ComputeFlow.test.ts
index d3a22d85..de505834 100644
--- a/test/integration/ComputeFlow.test.ts
+++ b/test/integration/ComputeFlow.test.ts
@@ -498,28 +498,30 @@ describe('Simple compute tests', async () => {
     assert(computeJobs, 'Cannot start compute job')
     computeJobId = computeJobs[0].jobId
 
-    await sleep(5000)
-    const jobStatus = (await ProviderInstance.computeStatus(
-      providerUrl,
-      consumerAccount,
-      computeJobId,
-      resolvedDdoWith1mTimeout.id
-    )) as ComputeJob
-    console.log('job status after 1 sec', jobStatus)
+    for (let index = 0; index < 10; index++) {
+      await sleep(1000)
+      const jobStatus = (await ProviderInstance.computeStatus(
+        providerUrl,
+        consumerAccount,
+        computeJobId,
+        resolvedDdoWith1mTimeout.id
+      )) as ComputeJob
+      console.log('job status after 1 sec', jobStatus)
+    }
   })
 
   it('should restart a computeJob without paying anything, because order is valid and providerFees are still valid', async () => {
     // wait 1 min time so the other compute job finishes his job
-    await sleep(10000)
-
-    const jobStatus = (await ProviderInstance.computeStatus(
-      providerUrl,
-      consumerAccount,
-      computeJobId,
-      resolvedDdoWith1mTimeout.id
-    )) as ComputeJob
-
-    console.log('job status after  15 sec', jobStatus)
+    for (let index = 0; index < 15; index++) {
+      await sleep(1000)
+      const jobStatus = (await ProviderInstance.computeStatus(
+        providerUrl,
+        consumerAccount,
+        computeJobId,
+        resolvedDdoWith1mTimeout.id
+      )) as ComputeJob
+      console.log('log job status again: ', jobStatus)
+    }
 
     // we choose the free env
     const computeEnv = computeEnvs.find((ce) => ce.priceMin === 0)