From 0a61082476f7d4d27c688d8d1db2234a00bf2d1d Mon Sep 17 00:00:00 2001 From: haixuanTao Date: Fri, 28 Jun 2024 11:06:16 +0200 Subject: [PATCH] Increasing grace duration to 2 seconds so that drop token get well returned or ignored --- binaries/daemon/src/lib.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/binaries/daemon/src/lib.rs b/binaries/daemon/src/lib.rs index 2ba349eb..b375c7c8 100644 --- a/binaries/daemon/src/lib.rs +++ b/binaries/daemon/src/lib.rs @@ -1567,7 +1567,7 @@ impl RunningDataflow { let running_nodes = self.running_nodes.clone(); let grace_duration_kills = self.grace_duration_kills.clone(); tokio::spawn(async move { - let duration = grace_duration.unwrap_or(Duration::from_millis(500)); + let duration = grace_duration.unwrap_or(Duration::from_millis(2000)); tokio::time::sleep(duration).await; let mut system = sysinfo::System::new(); system.refresh_processes();