diff --git a/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts b/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts index 26cd7c987f..79d6df4c9e 100644 --- a/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts +++ b/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts @@ -87,6 +87,9 @@ export const makeProcessFromRoot = async (config: NxtpLighthouseConfig, chainDat console.error("Error starting processor. Sad! :(", e); } finally { await closeDatabase(); - process.exit(); + + context.logger.info("Process from root complete!!!", requestContext, methodContext, { + chains: [...Object.keys(context.config.chains)], + }); } }; diff --git a/packages/agents/lighthouse/src/tasks/propagate/propagate.ts b/packages/agents/lighthouse/src/tasks/propagate/propagate.ts index 018fc28415..1a5ef8a288 100644 --- a/packages/agents/lighthouse/src/tasks/propagate/propagate.ts +++ b/packages/agents/lighthouse/src/tasks/propagate/propagate.ts @@ -91,6 +91,8 @@ export const makePropagate = async (config: NxtpLighthouseConfig, chainData: Map } catch (e: unknown) { console.error("Error starting Propagate task. Sad! :(", e); } finally { - process.exit(); + context.logger.info("Propagate task complete!", requestContext, methodContext, { + chains: [...Object.keys(context.config.chains)], + }); } }; diff --git a/packages/agents/lighthouse/src/tasks/prover/prover.ts b/packages/agents/lighthouse/src/tasks/prover/prover.ts index ccb2fff980..be36973977 100644 --- a/packages/agents/lighthouse/src/tasks/prover/prover.ts +++ b/packages/agents/lighthouse/src/tasks/prover/prover.ts @@ -16,6 +16,7 @@ import { acquireLock, prefetch, releaseLock } from "./operations/publisher"; const context: ProverContext = {} as any; export const getContext = () => context; export const makeProverPublisher = async (config: NxtpLighthouseConfig, chainData: Map) => { + const { requestContext, methodContext } = createLoggingContext(makeProverPublisher.name); try { await makeProver(config, chainData); if (!(await acquireLock())) throw new Error("Could not acquire lock"); @@ -30,7 +31,8 @@ export const makeProverPublisher = async (config: NxtpLighthouseConfig, chainDat console.error("Error starting Prover-Publisher. Sad! :(", e); } finally { await closeDatabase(); - process.exit(); + + context.logger.info("Prover complete!!!", requestContext, methodContext, {}); } };