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

search for issue

Browse Source
This commit is contained in:
Miquel A. Cabot 2022-06-06 13:01:58 +02:00
parent 733e70b686
commit 8e514e99c7
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -422,11 +422,16 @@ describe('Simple compute tests', async () => {
serviceId: resolvedDdoWith1mTimeout.services[0].id serviceId: resolvedDdoWith1mTimeout.services[0].id
} }
] ]
console.log(assets)
console.log(resolvedDdoWith1mTimeout.services[0].datatokenAddress)
const dtAddressArray = [resolvedDdoWith1mTimeout.services[0].datatokenAddress] const dtAddressArray = [resolvedDdoWith1mTimeout.services[0].datatokenAddress]
console.log(resolvedAlgoDdoWith1mTimeout.id)
console.log(resolvedAlgoDdoWith1mTimeout.services[0].id)
const algo: ComputeAlgorithm = { const algo: ComputeAlgorithm = {
documentId: resolvedAlgoDdoWith1mTimeout.id, documentId: resolvedAlgoDdoWith1mTimeout.id,
serviceId: resolvedAlgoDdoWith1mTimeout.services[0].id serviceId: resolvedAlgoDdoWith1mTimeout.services[0].id
} }
console.log(algo)
providerInitializeComputeResults = await ProviderInstance.initializeCompute( providerInitializeComputeResults = await ProviderInstance.initializeCompute(
assets, assets,
@ -436,6 +441,7 @@ describe('Simple compute tests', async () => {
providerUrl, providerUrl,
consumerAccount consumerAccount
) )
console.log(providerInitializeComputeResults)
assert( assert(
!('error' in providerInitializeComputeResults.algorithm), !('error' in providerInitializeComputeResults.algorithm),
'Cannot order algorithm' 'Cannot order algorithm'
@ -447,6 +453,7 @@ describe('Simple compute tests', async () => {
computeConsumerAddress, computeConsumerAddress,
0 0
) )
console.log(algo.transferTxId)
for (let i = 0; i < providerInitializeComputeResults.datasets.length; i++) { for (let i = 0; i < providerInitializeComputeResults.datasets.length; i++) {
assets[i].transferTxId = await handleOrder( assets[i].transferTxId = await handleOrder(
providerInitializeComputeResults.datasets[i], providerInitializeComputeResults.datasets[i],
@ -456,6 +463,7 @@ describe('Simple compute tests', async () => {
0 0
) )
} }
console.log(assets[0])
const computeJobs = await ProviderInstance.computeStart( const computeJobs = await ProviderInstance.computeStart(
providerUrl, providerUrl,
web3, web3,