diff --git a/queue/abstract/driver/fifottl.lua b/queue/abstract/driver/fifottl.lua
index b0c6def1..44bd52f3 100644
--- a/queue/abstract/driver/fifottl.lua
+++ b/queue/abstract/driver/fifottl.lua
@@ -124,6 +124,7 @@ function method._fiber(self)
                 if now >= task[i_next_event] then
                     self.space:delete(task[i_id])
                     self:on_task_change(task:transform(2, 1, state.DONE))
+                    estimated = 0
                 else
                     local et = tonumber(task[i_next_event] - now) / 1000000
                     if et < estimated then
diff --git a/queue/abstract/driver/utubettl.lua b/queue/abstract/driver/utubettl.lua
index 73d61d9f..867ade27 100644
--- a/queue/abstract/driver/utubettl.lua
+++ b/queue/abstract/driver/utubettl.lua
@@ -142,6 +142,7 @@ function method._fiber(self)
                 if now >= task[i_next_event] then
                     self.space:delete(task[i_id])
                     self:on_task_change(task:transform(2, 1, state.DONE))
+                    estimated = 0
                 else
                     local et = tonumber(task[i_next_event] - now) / 1000000
                     if et < estimated then