diff --git a/fdbclient/NativeAPI.actor.cpp b/fdbclient/NativeAPI.actor.cpp index 7dbf08cdc7..171cf09a93 100644 --- a/fdbclient/NativeAPI.actor.cpp +++ b/fdbclient/NativeAPI.actor.cpp @@ -224,7 +224,7 @@ template <> void delref( DatabaseContext* ptr ) { ptr->delref(); } ACTOR Future databaseLogger( DatabaseContext *cx ) { state double lastLogged = 0; loop { - wait(delay(CLIENT_KNOBS->SYSTEM_MONITOR_INTERVAL, cx->taskID)); + wait(delay(CLIENT_KNOBS->SYSTEM_MONITOR_INTERVAL, TaskPriority::FlushTrace)); TraceEvent ev("TransactionMetrics", cx->dbId); ev.detail("Elapsed", (lastLogged == 0) ? 0 : now() - lastLogged) diff --git a/flow/Stats.actor.cpp b/flow/Stats.actor.cpp index d621188277..5f966cb47b 100644 --- a/flow/Stats.actor.cpp +++ b/flow/Stats.actor.cpp @@ -95,6 +95,6 @@ ACTOR Future traceCounters(std::string traceEventName, UID traceEventID, d } last_interval = now(); - wait(delay(interval)); + wait(delay(interval, TaskPriority::FlushTrace)); } }