Use second-based DATETIME_DIFF in urine_output_rate

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: Chessing234

mimic-iv/concepts/measurement/urine_output_rate.sql

@@ -16,12 +16,14 @@ WITH tm AS (
 )
 
 -- now calculate time since last UO measurement
+-- Use SECOND then convert so BigQuery (truncating) and Postgres (fractional)
+-- DATETIME_DIFF agree; same approach as kdigo_uo.sql.
 , uo_tm AS (
     SELECT tm.stay_id
         , CASE
             WHEN LAG(charttime) OVER w IS NULL
-                THEN DATETIME_DIFF(charttime, intime_hr, MINUTE)
-            ELSE DATETIME_DIFF(charttime, LAG(charttime) OVER w, MINUTE)
+                THEN DATETIME_DIFF(charttime, intime_hr, SECOND) / 60.0
+            ELSE DATETIME_DIFF(charttime, LAG(charttime) OVER w, SECOND) / 60.0
         END AS tm_since_last_uo
         , uo.charttime
         , uo.urineoutput
@@ -45,26 +47,37 @@ WITH tm AS (
         -- to 1 hour of UO, therefore we use '5' and '11' to restrict the
         -- period, rather than 6/12 this assumption may overestimate UO rate
         -- when documentation is done less than hourly
-        , SUM(CASE WHEN DATETIME_DIFF(io.charttime, iosum.charttime, HOUR) <= 5
+        , SUM(CASE
+            WHEN DATETIME_DIFF(
+                    io.charttime, iosum.charttime, SECOND
+                ) / 3600.0 <= 5
             THEN iosum.urineoutput
             ELSE NULL END) AS urineoutput_6hr
         , ROUND(CAST(
             SUM(
                 CASE
-                    WHEN DATETIME_DIFF(io.charttime, iosum.charttime, HOUR) <= 5
-                THEN iosum.tm_since_last_uo
-                ELSE NULL END) / 60.0 AS NUMERIC
+                    WHEN DATETIME_DIFF(
+                            io.charttime, iosum.charttime, SECOND
+                        ) / 3600.0 <= 5
+                    THEN iosum.tm_since_last_uo
+                    ELSE NULL END
+            ) / 60.0 AS NUMERIC
         ), 6) AS uo_tm_6hr
-        , SUM(CASE WHEN DATETIME_DIFF(io.charttime, iosum.charttime, HOUR) <= 11
+        , SUM(CASE
+            WHEN DATETIME_DIFF(
+                    io.charttime, iosum.charttime, SECOND
+                ) / 3600.0 <= 11
             THEN iosum.urineoutput
             ELSE NULL END) AS urineoutput_12hr
         , ROUND(CAST(
             SUM(
                 CASE
-                    WHEN
-                        DATETIME_DIFF(io.charttime, iosum.charttime, HOUR) <= 11
-                THEN iosum.tm_since_last_uo
-                ELSE NULL END) / 60.0 AS NUMERIC
+                    WHEN DATETIME_DIFF(
+                            io.charttime, iosum.charttime, SECOND
+                        ) / 3600.0 <= 11
+                    THEN iosum.tm_since_last_uo
+                    ELSE NULL END
+            ) / 60.0 AS NUMERIC
         ), 6) AS uo_tm_12hr
         -- 24 hours
         , SUM(iosum.urineoutput) AS urineoutput_24hr

mimic-iv/concepts_duckdb/measurement/urine_output_rate.sql

@@ -18,8 +18,8 @@ WITH tm AS (
     tm.stay_id,
     CASE
       WHEN LAG(charttime) OVER w IS NULL
-      THEN DATE_DIFF('MINUTE', intime_hr, charttime)
-      ELSE DATE_DIFF('MINUTE', LAG(charttime) OVER w, charttime)
+      THEN DATE_DIFF('SECOND', intime_hr, charttime) / 60.0
+      ELSE DATE_DIFF('SECOND', LAG(charttime) OVER w, charttime) / 60.0
     END AS tm_since_last_uo,
     uo.charttime,
     uo.urineoutput
@@ -34,15 +34,15 @@ WITH tm AS (
     SUM(DISTINCT io.urineoutput) AS uo,
     SUM(
       CASE
-        WHEN DATE_DIFF('HOUR', iosum.charttime, io.charttime) <= 5
+        WHEN DATE_DIFF('SECOND', iosum.charttime, io.charttime) / 3600.0 <= 5
         THEN iosum.urineoutput
         ELSE NULL
       END
     ) AS urineoutput_6hr,
     ROUND(
       CAST(SUM(
         CASE
-          WHEN DATE_DIFF('HOUR', iosum.charttime, io.charttime) <= 5
+          WHEN DATE_DIFF('SECOND', iosum.charttime, io.charttime) / 3600.0 <= 5
           THEN iosum.tm_since_last_uo
           ELSE NULL
         END
@@ -51,15 +51,15 @@ WITH tm AS (
     ) AS uo_tm_6hr,
     SUM(
       CASE
-        WHEN DATE_DIFF('HOUR', iosum.charttime, io.charttime) <= 11
+        WHEN DATE_DIFF('SECOND', iosum.charttime, io.charttime) / 3600.0 <= 11
         THEN iosum.urineoutput
         ELSE NULL
       END
     ) AS urineoutput_12hr,
     ROUND(
       CAST(SUM(
         CASE
-          WHEN DATE_DIFF('HOUR', iosum.charttime, io.charttime) <= 11
+          WHEN DATE_DIFF('SECOND', iosum.charttime, io.charttime) / 3600.0 <= 11
           THEN iosum.tm_since_last_uo
           ELSE NULL
         END

mimic-iv/concepts_postgres/measurement/urine_output_rate.sql

@@ -1,6 +1,9 @@
 -- THIS SCRIPT IS AUTOMATICALLY GENERATED. DO NOT EDIT IT DIRECTLY.
 DROP TABLE IF EXISTS mimiciv_derived.urine_output_rate; CREATE TABLE mimiciv_derived.urine_output_rate AS
-/* attempt to calculate urine output per hour */ /* rate/hour is the interpretable measure of kidney function */ /* though it is difficult to estimate from aperiodic point measures */ /* first we get the earliest heart rate documented for the stay */
+/* attempt to calculate urine output per hour */
+/* rate/hour is the interpretable measure of kidney function */
+/* though it is difficult to estimate from aperiodic point measures */
+/* first we get the earliest heart rate documented for the stay */
 WITH tm AS (
   SELECT
     ie.stay_id,
@@ -14,13 +17,13 @@ WITH tm AS (
     AND ce.charttime < ie.outtime + INTERVAL '1' MONTH
   GROUP BY
     ie.stay_id
-), uo_tm /* now calculate time since last UO measurement */ AS (
+), uo_tm /* now calculate time since last UO measurement */ /* Use SECOND then convert so BigQuery (truncating) and Postgres (fractional) */ /* DATETIME_DIFF agree; same approach as kdigo_uo.sql. */ AS (
   SELECT
     tm.stay_id,
     CASE
       WHEN LAG(charttime) OVER w IS NULL
-      THEN CAST(EXTRACT(EPOCH FROM DATE_TRUNC('minute', charttime) - DATE_TRUNC('minute', intime_hr)) / 60 AS BIGINT)
-      ELSE CAST(EXTRACT(EPOCH FROM DATE_TRUNC('minute', charttime) - DATE_TRUNC('minute', LAG(charttime) OVER w)) / 60 AS BIGINT)
+      THEN CAST(CAST(EXTRACT(EPOCH FROM DATE_TRUNC('second', charttime) - DATE_TRUNC('second', intime_hr)) / 1 AS BIGINT) AS DOUBLE PRECISION) / 60.0
+      ELSE CAST(CAST(EXTRACT(EPOCH FROM DATE_TRUNC('second', charttime) - DATE_TRUNC('second', LAG(charttime) OVER w)) / 1 AS BIGINT) AS DOUBLE PRECISION) / 60.0
     END AS tm_since_last_uo,
     uo.charttime,
     uo.urineoutput
@@ -35,15 +38,15 @@ WITH tm AS (
     SUM(DISTINCT io.urineoutput) AS uo, /* note that we assume data charted at charttime corresponds */ /* to 1 hour of UO, therefore we use '5' and '11' to restrict the */ /* period, rather than 6/12 this assumption may overestimate UO rate */ /* when documentation is done less than hourly */
     SUM(
       CASE
-        WHEN CAST(EXTRACT(EPOCH FROM DATE_TRUNC('hour', io.charttime) - DATE_TRUNC('hour', iosum.charttime)) / 3600 AS BIGINT) <= 5
+        WHEN CAST(CAST(EXTRACT(EPOCH FROM DATE_TRUNC('second', io.charttime) - DATE_TRUNC('second', iosum.charttime)) / 1 AS BIGINT) AS DOUBLE PRECISION) / 3600.0 <= 5
         THEN iosum.urineoutput
         ELSE NULL
       END
     ) AS urineoutput_6hr,
     ROUND(
       CAST(CAST(SUM(
         CASE
-          WHEN CAST(EXTRACT(EPOCH FROM DATE_TRUNC('hour', io.charttime) - DATE_TRUNC('hour', iosum.charttime)) / 3600 AS BIGINT) <= 5
+          WHEN CAST(CAST(EXTRACT(EPOCH FROM DATE_TRUNC('second', io.charttime) - DATE_TRUNC('second', iosum.charttime)) / 1 AS BIGINT) AS DOUBLE PRECISION) / 3600.0 <= 5
           THEN iosum.tm_since_last_uo
           ELSE NULL
         END
@@ -52,15 +55,15 @@ WITH tm AS (
     ) AS uo_tm_6hr,
     SUM(
       CASE
-        WHEN CAST(EXTRACT(EPOCH FROM DATE_TRUNC('hour', io.charttime) - DATE_TRUNC('hour', iosum.charttime)) / 3600 AS BIGINT) <= 11
+        WHEN CAST(CAST(EXTRACT(EPOCH FROM DATE_TRUNC('second', io.charttime) - DATE_TRUNC('second', iosum.charttime)) / 1 AS BIGINT) AS DOUBLE PRECISION) / 3600.0 <= 11
         THEN iosum.urineoutput
         ELSE NULL
       END
     ) AS urineoutput_12hr,
     ROUND(
       CAST(CAST(SUM(
         CASE
-          WHEN CAST(EXTRACT(EPOCH FROM DATE_TRUNC('hour', io.charttime) - DATE_TRUNC('hour', iosum.charttime)) / 3600 AS BIGINT) <= 11
+          WHEN CAST(CAST(EXTRACT(EPOCH FROM DATE_TRUNC('second', io.charttime) - DATE_TRUNC('second', iosum.charttime)) / 1 AS BIGINT) AS DOUBLE PRECISION) / 3600.0 <= 11
           THEN iosum.tm_since_last_uo
           ELSE NULL
         END