remove erronous error log in agent mode
This commit is contained in:
@@ -466,6 +466,12 @@ pub enum JobCompletedSender {
|
||||
NeverUsed,
|
||||
}
|
||||
|
||||
impl JobCompletedSender {
|
||||
pub fn is_sql(&self) -> bool {
|
||||
matches!(self, Self::Sql(_))
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Clone)]
|
||||
pub struct SqlJobCompletedSender {
|
||||
sender: flume::Sender<SendResult>,
|
||||
@@ -1536,7 +1542,7 @@ pub async fn run_worker(
|
||||
Ok(_) | Err(broadcast::error::TryRecvError::Closed) => true,
|
||||
_ => false,
|
||||
} {
|
||||
if !killed_but_draining_same_worker_jobs {
|
||||
if !killed_but_draining_same_worker_jobs && job_completed_tx.is_sql() {
|
||||
killed_but_draining_same_worker_jobs = true;
|
||||
tracing::info!(worker = %worker_name, hostname = %hostname, "killpill received in worker main loop, sending killpill job");
|
||||
job_completed_tx
|
||||
|
||||
Reference in New Issue
Block a user