File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
lambdas/parquet-concat/src Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -66,8 +66,12 @@ async fn function_handler(event: LambdaEvent<SqsEvent>) -> Result<(), Error> {
6666 let mut last_writer: Option < AsyncArrowWriter < ParquetObjectWriter > > = None ;
6767 let mut last_dir: Option < String > = None ;
6868
69- let max_retries: usize = std:: env:: var ( "MAX_RETRIES" ) . unwrap_or ( "20" . to_string ( ) ) . parse ( ) ?;
70- let init_backoff_ms: u64 = std:: env:: var ( "INIT_BACKOFF_MS" ) . unwrap_or ( "500" . to_string ( ) ) . parse ( ) ?;
69+ let max_retries: usize = std:: env:: var ( "MAX_RETRIES" )
70+ . unwrap_or ( "20" . to_string ( ) )
71+ . parse ( ) ?;
72+ let init_backoff_ms: u64 = std:: env:: var ( "INIT_BACKOFF_MS" )
73+ . unwrap_or ( "500" . to_string ( ) )
74+ . parse ( ) ?;
7175
7276 let retry = RetryConfig {
7377 backoff : BackoffConfig {
You can’t perform that action at this time.
0 commit comments