@@ -659,7 +659,7 @@ export class C2DEngineDocker extends C2DEngine {
659659
660660 private async cleanUpUnknownLocks ( chain : string , currentTimestamp : bigint ) {
661661 try {
662- const nodeAddress = await this . getKeyManager ( ) . getEthAddress ( )
662+ const nodeAddress = this . getKeyManager ( ) . getEthAddress ( )
663663 const jobIds : any [ ] = [ ]
664664 const tokens : string [ ] = [ ]
665665 const payer : string [ ] = [ ]
@@ -1414,7 +1414,7 @@ export class C2DEngineDocker extends C2DEngine {
14141414 if ( ! jobRes [ 0 ] . isRunning ) return null
14151415 try {
14161416 const job = jobRes [ 0 ]
1417- const container = await this . docker . getContainer ( job . jobId + '-algoritm' )
1417+ const container = this . docker . getContainer ( job . jobId + '-algoritm' )
14181418 const details = await container . inspect ( )
14191419 if ( details . State . Running === false ) return null
14201420 return await container . logs ( {
@@ -1765,7 +1765,7 @@ export class C2DEngineDocker extends C2DEngine {
17651765 let container
17661766 let details
17671767 try {
1768- container = await this . docker . getContainer ( job . jobId + '-algoritm' )
1768+ container = this . docker . getContainer ( job . jobId + '-algoritm' )
17691769 details = await container . inspect ( )
17701770 } catch ( e ) {
17711771 console . error (
@@ -1867,7 +1867,7 @@ export class C2DEngineDocker extends C2DEngine {
18671867 job . statusText = C2DStatusText . JobSettle
18681868 let container
18691869 try {
1870- container = await this . docker . getContainer ( job . jobId + '-algoritm' )
1870+ container = this . docker . getContainer ( job . jobId + '-algoritm' )
18711871 } catch ( e ) {
18721872 CORE_LOGGER . debug ( 'Could not retrieve container: ' + e . message )
18731873 job . isRunning = false
@@ -2056,7 +2056,7 @@ export class C2DEngineDocker extends C2DEngine {
20562056 this . releaseCpus ( job . jobId )
20572057
20582058 try {
2059- const container = await this . docker . getContainer ( job . jobId + '-algoritm' )
2059+ const container = this . docker . getContainer ( job . jobId + '-algoritm' )
20602060 if ( container ) {
20612061 if ( job . status !== C2DStatusNumber . AlgorithmFailed ) {
20622062 writeFileSync (
@@ -2748,24 +2748,25 @@ export class C2DEngineDocker extends C2DEngine {
27482748 const destination = jobFolderPath + '/tarData/upload.tar.gz'
27492749 try {
27502750 tar . create (
2751+ // map is a valid runtime option but missing from type definitions
27512752 {
27522753 gzip : true ,
27532754 file : destination ,
27542755 sync : true ,
27552756 C : folderToTar ,
2756- map : ( header ) => {
2757+ map : ( header : any ) => {
27572758 header . uid = C2D_CONTAINER_UID
27582759 header . gid = C2D_CONTAINER_GID
27592760 return header
27602761 }
2761- } ,
2762+ } as any ,
27622763 [ './' ]
27632764 )
27642765 // check if tar.gz actually exists
27652766
27662767 if ( existsSync ( destination ) ) {
27672768 // now, upload it to the container
2768- const container = await this . docker . getContainer ( job . jobId + '-algoritm' )
2769+ const container = this . docker . getContainer ( job . jobId + '-algoritm' )
27692770
27702771 try {
27712772 // await container2.putArchive(destination, {
@@ -2851,7 +2852,7 @@ export class C2DEngineDocker extends C2DEngine {
28512852 }
28522853
28532854 // delete output folders
2854- await this . deleteOutputFolder ( job )
2855+ this . deleteOutputFolder ( job )
28552856 // delete the job
28562857 await this . db . deleteJob ( job . jobId )
28572858 return true
0 commit comments