From 626a91b80c06586db5b8feb410a99eaa66b00bf3 Mon Sep 17 00:00:00 2001 From: sundy-li <543950155@qq.com> Date: Mon, 27 May 2024 16:54:29 +0800 Subject: [PATCH] feat(query): add async retry transform --- .../src/pipelines/processors/transforms/transform_udf_server.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/query/service/src/pipelines/processors/transforms/transform_udf_server.rs b/src/query/service/src/pipelines/processors/transforms/transform_udf_server.rs index 0532349da24a..79c55f40d3fb 100644 --- a/src/query/service/src/pipelines/processors/transforms/transform_udf_server.rs +++ b/src/query/service/src/pipelines/processors/transforms/transform_udf_server.rs @@ -54,7 +54,7 @@ impl TransformUdfServer { } impl AsyncRetry for TransformUdfServer { - fn retry_on(&self, err: &databend_common_exception::ErrorCode) -> bool { + fn retry_on(&self, _err: &databend_common_exception::ErrorCode) -> bool { true }