Skip to content

Commit

Permalink
Increasing grace duration to 2 seconds so that drop token get well re…
Browse files Browse the repository at this point in the history
…turned or ignored
  • Loading branch information
haixuanTao committed Jun 28, 2024
1 parent 3298443 commit 1f06034
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion binaries/daemon/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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(1000));
let duration = grace_duration.unwrap_or(Duration::from_millis(2000));
tokio::time::sleep(duration).await;
let mut system = sysinfo::System::new();
system.refresh_processes();
Expand Down

0 comments on commit 1f06034

Please sign in to comment.