more replica fixes

adjust · Aug 30, 2017 · bb70656 · bb70656
1 parent 444dd58
commit bb70656
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/extension/pgtelemetry--0.1--1.0.sql b/extension/pgtelemetry--0.1--1.0.sql
@@ -69,7 +69,7 @@ $$
 declare log_entry pg_telemetry_wal_log;
 begin
     if pg_is_in_recovery() then
-       select * into log_entry from pg_telemetry_wal_log order by current_epoch desc limit 1;
+       select * into log_entry from pg_telemetry_wal_log order by run_time desc limit 1;
     else
        insert into pg_telemetry_wal_log
        select extract('epoch' from now()), now(),

diff --git a/extension/pgtelemetry--0.2--1.0.sql b/extension/pgtelemetry--0.2--1.0.sql
@@ -5,7 +5,7 @@ $$
 declare log_entry pg_telemetry_wal_log;
 begin
     if pg_is_in_recovery() then
-       select * into log_entry from pg_telemetry_wal_log order by current_epoch desc limit 1;
+       select * into log_entry from pg_telemetry_wal_log order by run_time desc limit 1;
     else
        insert into pg_telemetry_wal_log
        select extract('epoch' from now()), now(),

diff --git a/extension/pgtelemetry--1.0.sql b/extension/pgtelemetry--1.0.sql
@@ -337,7 +337,7 @@ $$
 declare log_entry pg_telemetry_wal_log;
 begin
     if pg_is_in_recovery() then
-       select * into log_entry from pg_telemetry_wal_log order by current_epoch desc limit 1;
+       select * into log_entry from pg_telemetry_wal_log order by run_time desc limit 1;
     else
        insert into pg_telemetry_wal_log
        select extract('epoch' from now()), now(),