diff --git a/liquibase-service/src/main/resources/db/rdb/routines/001-generate_data_for_data_sync_config-004.sql b/liquibase-service/src/main/resources/db/rdb/routines/001-generate_data_for_data_sync_config-004.sql
new file mode 100644
index 00000000..a2ecf14f
--- /dev/null
+++ b/liquibase-service/src/main/resources/db/rdb/routines/001-generate_data_for_data_sync_config-004.sql
@@ -0,0 +1,34 @@
+-- Removing existing nrt_obs_coded query, which wasn't correct
+DELETE
+FROM [dbo].[data_sync_config]
+WHERE table_name = 'NRT_OBSERVATION_CODED';
+
+-- Inserting valid query back into the config
+INSERT INTO [dbo].[data_sync_config]
+(table_name, source_db, query, query_with_null_timestamp, query_count, query_with_pagination)
+VALUES
+    ('NRT_OBSERVATION_CODED', 'RDB_MODERN', 'SELECT rdb_modern.dbo.nrt_observation_coded.*
+     FROM rdb_modern.dbo.nrt_observation_coded
+     JOIN rdb_modern.dbo.nrt_observation
+     ON rdb_modern.dbo.nrt_observation_coded.observation_uid = rdb_modern.dbo.nrt_observation.observation_uid
+     WHERE rdb_modern.dbo.nrt_observation_coded.refresh_datetime :operator :timestamp
+     OR rdb_modern.dbo.nrt_observation.last_chg_time :operator :timestamp
+     OR rdb_modern.dbo.nrt_observation.refresh_datetime :operator :timestamp;', NULL, 'SELECT COUNT(*)
+     FROM rdb_modern.dbo.nrt_observation_coded
+     JOIN rdb_modern.dbo.nrt_observation
+     ON rdb_modern.dbo.nrt_observation_coded.observation_uid = rdb_modern.dbo.nrt_observation.observation_uid
+     WHERE rdb_modern.dbo.nrt_observation_coded.refresh_datetime :operator :timestamp
+     OR rdb_modern.dbo.nrt_observation.last_chg_time :operator :timestamp
+     OR rdb_modern.dbo.nrt_observation.refresh_datetime :operator :timestamp;', 'WITH PaginatedResults AS (
+        SELECT rdb_modern.dbo.nrt_observation_coded.*,
+               ROW_NUMBER() OVER (ORDER BY (SELECT NULL)) AS RowNum
+        FROM rdb_modern.dbo.nrt_observation_coded
+        JOIN rdb_modern.dbo.nrt_observation
+        ON rdb_modern.dbo.nrt_observation_coded.observation_uid = rdb_modern.dbo.nrt_observation.observation_uid
+        WHERE rdb_modern.dbo.nrt_observation_coded.refresh_datetime :operator :timestamp
+        OR rdb_modern.dbo.nrt_observation.last_chg_time :operator :timestamp
+        OR rdb_modern.dbo.nrt_observation.refresh_datetime :operator :timestamp
+    )
+    SELECT * FROM PaginatedResults
+    WHERE RowNum BETWEEN :startRow AND :endRow;')
+;