diff --git a/plugins/producer_plugin/producer_plugin.cpp b/plugins/producer_plugin/producer_plugin.cpp index e57fe48f54..c610d9b5b6 100644 --- a/plugins/producer_plugin/producer_plugin.cpp +++ b/plugins/producer_plugin/producer_plugin.cpp @@ -396,7 +396,7 @@ class producer_plugin_impl : public std::enable_shared_from_thisactive_schedule.producers, - _producer_watermarks); - if (wake_time) - _pending_block_deadline = std::min(*wake_time, _pending_block_deadline); } const auto& preprocess_deadline = _pending_block_deadline;