diff --git a/ingestion/src/metadata/ingestion/source/database/mssql/queries.py b/ingestion/src/metadata/ingestion/source/database/mssql/queries.py
index d9bab948e08..0ed3f06da06 100644
--- a/ingestion/src/metadata/ingestion/source/database/mssql/queries.py
+++ b/ingestion/src/metadata/ingestion/source/database/mssql/queries.py
@@ -20,8 +20,8 @@ MSSQL_SQL_STATEMENT = textwrap.dedent(
         db.NAME database_name,
         t.text query_text,
         s.last_execution_time start_time,
-        DATEADD(s, s.total_elapsed_time/1000, s.last_execution_time) end_time,
-        s.total_elapsed_time/1000 duration,
+        DATEADD(s, s.last_elapsed_time/1000000, s.last_execution_time) end_time,
+        s.last_elapsed_time/1000000 duration,
         NULL schema_name,
         NULL query_type,
         NULL user_name,
@@ -209,7 +209,7 @@ MSSQL_GET_STORED_PROCEDURE_QUERIES = textwrap.dedent(
 WITH SP_HISTORY (start_time, end_time, procedure_name, query_text) AS (
   select 
     s.last_execution_time start_time,
-    DATEADD(s, s.total_elapsed_time/1000, s.last_execution_time) end_time,
+    DATEADD(s, s.last_elapsed_time/1000000, s.last_execution_time) end_time,
     OBJECT_NAME(object_id, database_id) as procedure_name,
     text as query_text
   from sys.dm_exec_procedure_stats s
@@ -222,8 +222,8 @@ Q_HISTORY (database_name, query_text, start_time, end_time, duration,query_type,
     db.NAME database_name,
     t.text query_text,
     s.last_execution_time start_time,
-    DATEADD(s, s.total_elapsed_time/1000, s.last_execution_time) end_time,
-    s.total_elapsed_time/1000 duration,
+    DATEADD(s, s.last_elapsed_time/1000000, s.last_execution_time) end_time,
+    s.last_elapsed_time/1000000 duration,
     case
         when t.text LIKE '%%MERGE%%' then 'MERGE'
         when t.text LIKE '%%UPDATE%%' then 'UPDATE'