diff --git a/src/event-replay/parquet-based/replay-controller.ts b/src/event-replay/parquet-based/replay-controller.ts
index 5e22939f..409abf34 100644
--- a/src/event-replay/parquet-based/replay-controller.ts
+++ b/src/event-replay/parquet-based/replay-controller.ts
@@ -14,6 +14,9 @@ import { IndexesState } from '../../datastore/common';
 import * as _cluster from 'cluster';
 const cluster = (_cluster as unknown) as _cluster.Cluster; // typings fix
 
+import { FILE_PATH as raw_worker_path } from './workers/raw-worker'
+import { FILE_PATH as new_block_worker_path } from './workers/new-block-worker'
+
 export class ReplayController {
   private readonly db;
   private readonly dataset;
@@ -110,7 +113,7 @@ export class ReplayController {
   ingestRawNewBlockEvents = async () => {
     return new Promise(async resolve => {
       cluster.setupPrimary({
-        exec: __dirname + '/workers/raw-worker',
+        exec: raw_worker_path,
       });
 
       let workersReady = 0;
@@ -150,7 +153,7 @@ export class ReplayController {
   ingestNewBlockEvents = (): Promise<boolean> => {
     return new Promise(async resolve => {
       cluster.setupPrimary({
-        exec: __dirname + '/workers/new-block-worker',
+        exec: new_block_worker_path,
       });
 
       let workersReady = 0;
diff --git a/src/event-replay/parquet-based/workers/new-block-worker.ts b/src/event-replay/parquet-based/workers/new-block-worker.ts
index e7d7b485..2cfd8c93 100644
--- a/src/event-replay/parquet-based/workers/new-block-worker.ts
+++ b/src/event-replay/parquet-based/workers/new-block-worker.ts
@@ -7,6 +7,8 @@ import { DatasetStore } from '../dataset/store';
 import { logger } from '../../../logger';
 import { createTimeTracker } from '../helpers';
 
+export const FILE_PATH = __filename;
+
 const ingestNewBlock = async (idFile?: string) => {
   const db = await PgWriteStore.connect({
     usageName: `${idFile}`,
diff --git a/src/event-replay/parquet-based/workers/raw-worker.ts b/src/event-replay/parquet-based/workers/raw-worker.ts
index 04fb370b..2795cb57 100644
--- a/src/event-replay/parquet-based/workers/raw-worker.ts
+++ b/src/event-replay/parquet-based/workers/raw-worker.ts
@@ -7,6 +7,8 @@ import { logger } from '../../../logger';
 import { createTimeTracker } from '../helpers';
 import { processRawEventsInParallel } from '../importers/raw-importer';
 
+export const FILE_PATH = __filename;
+
 const ingestNewBlock = async (idFile?: string) => {
   const db = await PgWriteStore.connect({
     usageName: `${idFile}`,