oceanprotocol/ocean.js
1
0
Fork 0
mirror of https://github.com/oceanprotocol/ocean.js.git synced 2024-11-26 20:39:05 +01:00
Code Releases Activity

log job status

Browse Source
This commit is contained in:
Bogdan Fazakas 2022-08-23 10:17:09 +03:00
parent d013cd65e1
commit 5d4c07a7f8
1 changed files with 20 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
test/integration/ComputeFlow.test.ts
View File

@ -497,11 +497,29 @@ describe('Simple compute tests', async () => {
freeEnvAlgoTxId = algo.transferTxId freeEnvAlgoTxId = algo.transferTxId
assert(computeJobs, 'Cannot start compute job') assert(computeJobs, 'Cannot start compute job')
computeJobId = computeJobs[0].jobId 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)
}) })
it('should restart a computeJob without paying anything, because order is valid and providerFees are still valid', async () => { 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 // wait 1 min time so the other compute job finishes his job
await sleep(15000) await sleep(10000)
const jobStatus = (await ProviderInstance.computeStatus(
providerUrl,
consumerAccount,
computeJobId,
resolvedDdoWith1mTimeout.id
)) as ComputeJob
console.log('job status after 15 sec', jobStatus)
// we choose the free env // we choose the free env
const computeEnv = computeEnvs.find((ce) => ce.priceMin === 0) const computeEnv = computeEnvs.find((ce) => ce.priceMin === 0)
@ -867,7 +885,7 @@ describe('Simple compute tests', async () => {
}) })
it('Get download compute results url', async () => { it('Get download compute results url', async () => {
await sleep(5000) await sleep(10000)
const downloadURL = await ProviderInstance.getComputeResultUrl( const downloadURL = await ProviderInstance.getComputeResultUrl(
providerUrl, providerUrl,
web3, web3,