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

merge main, added logs, update container checksum

Browse Source
This commit is contained in:
Bogdan Fazakas 2022-08-11 11:45:33 +03:00
parent 49bca513d6
commit 61477269db
1 changed files with 23 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -176,7 +176,7 @@ const algoDdoWithNoTimeout = {
image: 'ubuntu', image: 'ubuntu',
tag: 'latest', tag: 'latest',
checksum: checksum:
'sha256:bace9fb0d5923a675c894d5c815da75ffe35e24970166a48a4460a48ae6e0d19' 'sha256:d39ab4712a8395d0b399dea44d9cb8b34ac942411b6a380449ebdb9d321136a3'
} }
} }
}, },
@ -218,7 +218,7 @@ const algoDdoWith1mTimeout = {
image: 'ubuntu', image: 'ubuntu',
tag: 'latest', tag: 'latest',
checksum: checksum:
'sha256:bace9fb0d5923a675c894d5c815da75ffe35e24970166a48a4460a48ae6e0d19' 'sha256:d39ab4712a8395d0b399dea44d9cb8b34ac942411b6a380449ebdb9d321136a3'
} }
} }
}, },
@ -481,20 +481,27 @@ describe('Simple compute tests', async () => {
) )
} }
console.log(' asset =', assets[0]) console.log(' asset =', assets[0])
console.log(' algo =', assets[0]) console.log(' algo =', algo)
const computeJobs = await ProviderInstance.computeStart( console.log(' consumerAccount =', consumerAccount)
providerUrl, console.log(' computeEnv.id =', computeEnv.id)
web3, try {
consumerAccount, const computeJobs = await ProviderInstance.computeStart(
computeEnv.id, providerUrl,
assets[0], web3,
algo consumerAccount,
) computeEnv.id,
console.log(' computeJobs response =', computeJobs) assets[0],
freeEnvDatasetTxId = assets[0].transferTxId algo
freeEnvAlgoTxId = algo.transferTxId )
assert(computeJobs, 'Cannot start compute job') console.log(' computeJobs response =', computeJobs)
computeJobId = computeJobs[0].jobId freeEnvDatasetTxId = assets[0].transferTxId
freeEnvAlgoTxId = algo.transferTxId
assert(computeJobs, 'Cannot start compute job')
computeJobId = computeJobs[0].jobId
} catch (error) {
console.log(' computeJobs error =', error)
console.log(' computeJobs error =', error.message)
}
}) })
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 () => {