diff --git a/airbyte-to-flow/src/connector_runner.rs b/airbyte-to-flow/src/connector_runner.rs index 1c09e15745fd..d364c8f85b3d 100644 --- a/airbyte-to-flow/src/connector_runner.rs +++ b/airbyte-to-flow/src/connector_runner.rs @@ -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 } }