@@ -124,8 +124,8 @@ export class Database {
124
124
125
125
// Acquire locks for all schemas
126
126
const chainDataLockId = generateLockId ( this . chainDataSchemaName ) ;
127
- const ipfsDataLockId = generateLockId ( this . ipfsDataSchemaName ) ;
128
- const priceDataLockId = generateLockId ( this . priceDataSchemaName ) ;
127
+ // const ipfsDataLockId = generateLockId(this.ipfsDataSchemaName);
128
+ // const priceDataLockId = generateLockId(this.priceDataSchemaName);
129
129
130
130
// Track acquired locks
131
131
const acquiredLocks : number [ ] = [ ] ;
@@ -140,16 +140,16 @@ export class Database {
140
140
// if (priceDataLockAcquired) acquiredLocks.push(priceDataLockId);
141
141
142
142
// NOTE: We are forcibly acquiring locks for IPFS and Price data schemas
143
- await forciblyAcquireLockForSchema ( priceDataLockId ) ;
144
- await forciblyAcquireLockForSchema ( priceDataLockId ) ;
145
- acquiredLocks . push ( ipfsDataLockId ) ;
146
- acquiredLocks . push ( priceDataLockId ) ;
147
-
148
- // this.#logger.info(`Lock Status =>
149
- // Chain Data (${chainDataLockId}): ${chainDataLockAcquired},
150
- // IPFS Data (${ipfsDataLockId}): ${ipfsDataLockAcquired},
151
- // Price Data (${priceDataLockId }): ${priceDataLockAcquired}
152
- // `);
143
+ // await forciblyAcquireLockForSchema(ipfsDataLockId );
144
+ // await forciblyAcquireLockForSchema(priceDataLockId);
145
+ // acquiredLocks.push(ipfsDataLockId);
146
+ // acquiredLocks.push(priceDataLockId);
147
+
148
+ this . #logger. info ( `Lock Status =>
149
+ Chain Data (${ chainDataLockId } ): ${ chainDataLockAcquired }
150
+ ` ) ;
151
+ // IPFS Data (${ipfsDataLockId }): ${ipfsDataLockAcquired},
152
+ // Price Data (${priceDataLockId}): ${priceDataLockAcquired}
153
153
154
154
return {
155
155
release : async ( ) => {
0 commit comments