diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jobs/JobDAO.java b/openmetadata-service/src/main/java/org/openmetadata/service/jobs/JobDAO.java
index 29fa5b61930..4a008560884 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/jobs/JobDAO.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/jobs/JobDAO.java
@@ -15,6 +15,7 @@ import org.jdbi.v3.sqlobject.customizer.Bind;
 import org.jdbi.v3.sqlobject.statement.GetGeneratedKeys;
 import org.jdbi.v3.sqlobject.statement.SqlQuery;
 import org.openmetadata.schema.jobs.BackgroundJob;
+import org.openmetadata.service.jdbi3.locator.ConnectionAwareSqlQuery;
 import org.openmetadata.service.jdbi3.locator.ConnectionAwareSqlUpdate;
 import org.openmetadata.service.util.JsonUtils;
 import org.slf4j.Logger;
@@ -65,11 +66,20 @@ public interface JobDAO {
     return Optional.ofNullable(fetchPendingJobInternal());
   }
 
-  @SqlQuery(
-      "SELECT id,jobType,methodName,jobArgs,status,createdAt,updatedAt,createdBy,runAt FROM background_jobs"
-          + " WHERE status = 'PENDING'"
-          + " AND COALESCE(runAt, 0) <= UNIX_TIMESTAMP(NOW(3)) * 1000"
-          + " ORDER BY createdAt LIMIT 1")
+  @ConnectionAwareSqlQuery(
+      value =
+          "SELECT id,jobType,methodName,jobArgs,status,createdAt,updatedAt,createdBy,runAt FROM background_jobs"
+              + " WHERE status = 'PENDING'"
+              + " AND COALESCE(runAt, 0) <= UNIX_TIMESTAMP(NOW(3)) * 1000"
+              + " ORDER BY createdAt LIMIT 1",
+      connectionType = MYSQL)
+  @ConnectionAwareSqlQuery(
+      value =
+          "SELECT id,jobType,methodName,jobArgs,status,createdAt,updatedAt,createdBy,runAt FROM background_jobs"
+              + " WHERE status = 'PENDING'"
+              + " AND COALESCE(runAt, 0) <= EXTRACT(EPOCH FROM NOW()) * 1000"
+              + " ORDER BY createdAt LIMIT 1",
+      connectionType = POSTGRES)
   @RegisterRowMapper(BackgroundJobMapper.class)
   BackgroundJob fetchPendingJobInternal() throws StatementException;