diff --git a/packages/api/src/logger.ts b/packages/api/src/logger.ts
index 8a53479c6a..d9c1fc7875 100644
--- a/packages/api/src/logger.ts
+++ b/packages/api/src/logger.ts
@@ -5,9 +5,11 @@ import { format, transports, Logform } from "winston";
 export const getLogger = (environment: string, logLevel: string): LoggerService => {
   let defaultLogLevel = "debug";
   const loggerFormatters: Logform.Format[] = [
-    format.timestamp({
-      format: "DD/MM/YYYY HH:mm:ss.SSS",
-    }),
+    environment === "production"
+      ? format.timestamp()
+      : format.timestamp({
+          format: "DD/MM/YYYY HH:mm:ss.SSS",
+        }),
     format.ms(),
     utilities.format.nestLike("API", {}),
   ];
diff --git a/packages/data-fetcher/src/logger.ts b/packages/data-fetcher/src/logger.ts
index 76f0e87c08..29d66a8d32 100644
--- a/packages/data-fetcher/src/logger.ts
+++ b/packages/data-fetcher/src/logger.ts
@@ -5,9 +5,11 @@ const { NODE_ENV, LOG_LEVEL } = process.env;
 
 let defaultLogLevel = "debug";
 const loggerFormatters: Logform.Format[] = [
-  format.timestamp({
-    format: "DD/MM/YYYY HH:mm:ss.SSS",
-  }),
+  NODE_ENV === "production"
+    ? format.timestamp()
+    : format.timestamp({
+        format: "DD/MM/YYYY HH:mm:ss.SSS",
+      }),
   format.ms(),
   utilities.format.nestLike("DataFetcher", {}),
 ];
diff --git a/packages/worker/src/config.spec.ts b/packages/worker/src/config.spec.ts
index f85c3f52d8..7cc332aec2 100644
--- a/packages/worker/src/config.spec.ts
+++ b/packages/worker/src/config.spec.ts
@@ -23,7 +23,7 @@ describe("config", () => {
       },
       dataFetcher: {
         url: "http://localhost:3040",
-        requestTimeout: 120_000,
+        requestTimeout: 60_000,
       },
       blocks: {
         waitForBlocksInterval: 1000,
diff --git a/packages/worker/src/config.ts b/packages/worker/src/config.ts
index b2884f949a..f8f82eb85e 100644
--- a/packages/worker/src/config.ts
+++ b/packages/worker/src/config.ts
@@ -41,7 +41,7 @@ export default () => {
     },
     dataFetcher: {
       url: DATA_FETCHER_URL || "http://localhost:3040",
-      requestTimeout: parseInt(DATA_FETCHER_REQUEST_TIMEOUT, 10) || 120_000,
+      requestTimeout: parseInt(DATA_FETCHER_REQUEST_TIMEOUT, 10) || 60_000,
     },
     blocks: {
       waitForBlocksInterval: parseInt(WAIT_FOR_BLOCKS_INTERVAL, 10) || 1000,
diff --git a/packages/worker/src/dataFetcher/dataFetcher.service.spec.ts b/packages/worker/src/dataFetcher/dataFetcher.service.spec.ts
index cf454d3bb6..e0aa9f08fe 100644
--- a/packages/worker/src/dataFetcher/dataFetcher.service.spec.ts
+++ b/packages/worker/src/dataFetcher/dataFetcher.service.spec.ts
@@ -5,9 +5,10 @@ import { HttpService } from "@nestjs/axios";
 import { ConfigService } from "@nestjs/config";
 import { AxiosResponse, AxiosError } from "axios";
 import * as rxjs from "rxjs";
+import { setTimeout } from "node:timers/promises";
 import { DataFetcherService } from "./dataFetcher.service";
 
-jest.mock("timers/promises", () => ({
+jest.mock("node:timers/promises", () => ({
   setTimeout: jest.fn().mockResolvedValue(null),
 }));
 
@@ -48,6 +49,7 @@ describe("DataFetcherService", () => {
 
   describe("getBlockData", () => {
     let pipeMock = jest.fn();
+    const blockData = { block: { number: 1 } };
 
     beforeEach(() => {
       pipeMock = jest.fn();
@@ -58,7 +60,6 @@ describe("DataFetcherService", () => {
     });
 
     it("returns block data", async () => {
-      const blockData = { block: { number: 1 } };
       pipeMock.mockReturnValueOnce(
         new rxjs.Observable((subscriber) => {
           subscriber.next({
@@ -75,25 +76,49 @@ describe("DataFetcherService", () => {
       expect(returnedBlockData).toEqual(blockData);
     });
 
-    it("throws an error if the request fails with populated response details", async () => {
+    it("retries the request if the request fails with populated response details", async () => {
       const error = new AxiosError("server error", "500", null, null, {
         status: 500,
         data: "error data",
       } as AxiosResponse<string, any>);
-      pipeMock.mockImplementation((callback) => {
+      pipeMock.mockImplementationOnce((callback) => {
         callback(error);
       });
 
-      await expect(dataFetcherService.getBlockData(1)).rejects.toThrowError(error);
+      pipeMock.mockReturnValueOnce(
+        new rxjs.Observable((subscriber) => {
+          subscriber.next({
+            data: [blockData],
+          });
+        })
+      );
+
+      const returnedBlockData = await dataFetcherService.getBlockData(1);
+      expect(httpServiceMock.get).toBeCalledTimes(2);
+      expect(setTimeout).toBeCalledTimes(1);
+      expect(setTimeout).toBeCalledWith(1000);
+      expect(returnedBlockData).toEqual(blockData);
     });
 
-    it("throws an error if the request fails without populated response details", async () => {
+    it("retries the request if the request fails without populated response details", async () => {
       const error = new AxiosError("server error", "500");
-      pipeMock.mockImplementation((callback) => {
+      pipeMock.mockImplementationOnce((callback) => {
         callback(error);
       });
 
-      await expect(dataFetcherService.getBlockData(1)).rejects.toThrowError(error);
+      pipeMock.mockReturnValueOnce(
+        new rxjs.Observable((subscriber) => {
+          subscriber.next({
+            data: [blockData],
+          });
+        })
+      );
+
+      const returnedBlockData = await dataFetcherService.getBlockData(1);
+      expect(httpServiceMock.get).toBeCalledTimes(2);
+      expect(setTimeout).toBeCalledTimes(1);
+      expect(setTimeout).toBeCalledWith(1000);
+      expect(returnedBlockData).toEqual(blockData);
     });
   });
 });
diff --git a/packages/worker/src/dataFetcher/dataFetcher.service.ts b/packages/worker/src/dataFetcher/dataFetcher.service.ts
index 9e92bca03e..629c2556e4 100644
--- a/packages/worker/src/dataFetcher/dataFetcher.service.ts
+++ b/packages/worker/src/dataFetcher/dataFetcher.service.ts
@@ -4,6 +4,9 @@ import { ConfigService } from "@nestjs/config";
 import { catchError, firstValueFrom } from "rxjs";
 import { AxiosError } from "axios";
 import { BlockData } from "./types";
+import { setTimeout } from "node:timers/promises";
+
+const DATA_FETCHER_RETRY_TIMEOUT = 1000;
 
 @Injectable()
 export class DataFetcherService {
@@ -18,10 +21,22 @@ export class DataFetcherService {
   }
 
   public async getBlockData(blockNumber: number): Promise<BlockData> {
-    const blocksData = await this.getBlocksData(blockNumber, blockNumber);
+    const blocksData = await this.getBlocksDataRetryable(blockNumber, blockNumber);
     return blocksData[0];
   }
 
+  private async getBlocksDataRetryable(from: number, to: number): Promise<BlockData[]> {
+    try {
+      return await this.getBlocksData(from, to);
+    } catch {
+      this.logger.debug({
+        message: `Retrying to fetch data for blocks: [${from}, ${to}]`,
+      });
+      await setTimeout(DATA_FETCHER_RETRY_TIMEOUT);
+      return this.getBlocksDataRetryable(from, to);
+    }
+  }
+
   private async getBlocksData(from: number, to: number): Promise<BlockData[]> {
     const queryString = new URLSearchParams({
       from: from.toString(),
diff --git a/packages/worker/src/logger.ts b/packages/worker/src/logger.ts
index 48476324d8..ff731998bc 100644
--- a/packages/worker/src/logger.ts
+++ b/packages/worker/src/logger.ts
@@ -5,9 +5,11 @@ const { NODE_ENV, LOG_LEVEL } = process.env;
 
 let defaultLogLevel = "debug";
 const loggerFormatters: Logform.Format[] = [
-  format.timestamp({
-    format: "DD/MM/YYYY HH:mm:ss.SSS",
-  }),
+  NODE_ENV === "production"
+    ? format.timestamp()
+    : format.timestamp({
+        format: "DD/MM/YYYY HH:mm:ss.SSS",
+      }),
   format.ms(),
   utilities.format.nestLike("Worker", {}),
 ];