From 9bfa8aab77bb6200ab94da066b9e4238dbfc1128 Mon Sep 17 00:00:00 2001 From: Johnny Graettinger Date: Tue, 30 Jan 2024 05:03:36 +0000 Subject: [PATCH] atf: increase idle connector timeout from 10m => 4 hours --- airbyte-to-flow/src/connector_runner.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 } }