Skip to content

Commit

Permalink
Fix workers
Browse files Browse the repository at this point in the history
  • Loading branch information
jiqiang90 committed Apr 9, 2024
1 parent baf0b4b commit 105d4a0
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,8 @@ export class AlgorandDictionaryService extends DictionaryService<
nodeConfig: NodeConfig,
eventEmitter: EventEmitter2,
protected dsProcessorService: DsProcessorService,
chainId?: string,
) {
super(chainId ?? project.network.chainId, nodeConfig, eventEmitter);
super(project.network.chainId, nodeConfig, eventEmitter);
}

private getV1Dictionary(): AlgorandDictionaryV1 | undefined {
Expand Down
12 changes: 6 additions & 6 deletions packages/node/src/indexer/worker/worker.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,11 @@ import {
IBlock,
} from '@subql/node-core';
import { AlgorandBlock, AlgorandDataSource } from '@subql/types-algorand';
import { AlgorandApi, SafeAPIService } from '../../algorand';
import {
AlgorandApi,
AlgorandApiService,
SafeAPIService,
} from '../../algorand';
import { AlgorandProjectDs } from '../../configure/SubqueryProject';
import { IndexerManager } from '../indexer.manager';
import { BlockContent } from '../types';
Expand Down Expand Up @@ -39,11 +43,7 @@ export class WorkerService extends BaseWorkerService<
{}
> {
constructor(
private apiService: ApiService<
AlgorandApi,
SafeAPIService,
IBlock<BlockContent>[]
>,
private apiService: AlgorandApiService,
private indexerManager: IndexerManager,
@Inject('IProjectService')
projectService: IProjectService<AlgorandProjectDs>,
Expand Down
2 changes: 1 addition & 1 deletion packages/node/src/indexer/worker/worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ const logger = getLogger(`worker #${threadId}`);
async function initWorker(startHeight: number): Promise<void> {
try {
const app = await NestFactory.create(WorkerModule, {
logger: new NestLogger(!!argv.debug), // TIP: If the worker is crashing comment out this line for better logging
// logger: new NestLogger(!!argv.debug), // TIP: If the worker is crashing comment out this line for better logging
});

await app.init();
Expand Down

0 comments on commit 105d4a0

Please sign in to comment.