Skip to content

Commit

Permalink
atf: increase idle connector timeout from 10m => 4 hours
Browse files Browse the repository at this point in the history
  • Loading branch information
jgraettinger authored and mdibaiee committed Jan 30, 2024
1 parent 0ce9177 commit 6266f7d
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions airbyte-to-flow/src/connector_runner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -113,13 +113,13 @@ pub async fn run_airbyte_source_connector(
let _ = ping_sender.try_send(());
});

// 10 minute timeout on ping
// Four hour timeout on inactivity.
let ping_timeout_task = async move {
loop {
tokio::select! {
Some(_) = ping_receiver.next() => { continue },
_ = tokio::time::sleep(tokio::time::Duration::from_secs(60 * 10)) => {
tracing::warn!("connector has been idle for the past 10 minutes. restarting.");
_ = tokio::time::sleep(tokio::time::Duration::from_secs(4 * 3600)) => {
tracing::warn!("Connector has been idle for the past four hours. Restarting...");
break
}
}
Expand Down

0 comments on commit 6266f7d

Please sign in to comment.