@@ -147,13 +147,13 @@ async def follow(
147147 if max_outstanding_read_requests is not None :
148148 __body ["max_outstanding_read_requests" ] = max_outstanding_read_requests
149149 if max_outstanding_write_requests is not None :
150- __body [
151- " max_outstanding_write_requests"
152- ] = max_outstanding_write_requests
150+ __body ["max_outstanding_write_requests" ] = (
151+ max_outstanding_write_requests
152+ )
153153 if max_read_request_operation_count is not None :
154- __body [
155- " max_read_request_operation_count"
156- ] = max_read_request_operation_count
154+ __body ["max_read_request_operation_count" ] = (
155+ max_read_request_operation_count
156+ )
157157 if max_read_request_size is not None :
158158 __body ["max_read_request_size" ] = max_read_request_size
159159 if max_retry_delay is not None :
@@ -163,9 +163,9 @@ async def follow(
163163 if max_write_buffer_size is not None :
164164 __body ["max_write_buffer_size" ] = max_write_buffer_size
165165 if max_write_request_operation_count is not None :
166- __body [
167- " max_write_request_operation_count"
168- ] = max_write_request_operation_count
166+ __body ["max_write_request_operation_count" ] = (
167+ max_write_request_operation_count
168+ )
169169 if max_write_request_size is not None :
170170 __body ["max_write_request_size" ] = max_write_request_size
171171 if read_poll_timeout is not None :
@@ -537,21 +537,21 @@ async def put_auto_follow_pattern(
537537 if follow_index_pattern is not None :
538538 __body ["follow_index_pattern" ] = follow_index_pattern
539539 if leader_index_exclusion_patterns is not None :
540- __body [
541- " leader_index_exclusion_patterns"
542- ] = leader_index_exclusion_patterns
540+ __body ["leader_index_exclusion_patterns" ] = (
541+ leader_index_exclusion_patterns
542+ )
543543 if leader_index_patterns is not None :
544544 __body ["leader_index_patterns" ] = leader_index_patterns
545545 if max_outstanding_read_requests is not None :
546546 __body ["max_outstanding_read_requests" ] = max_outstanding_read_requests
547547 if max_outstanding_write_requests is not None :
548- __body [
549- " max_outstanding_write_requests"
550- ] = max_outstanding_write_requests
548+ __body ["max_outstanding_write_requests" ] = (
549+ max_outstanding_write_requests
550+ )
551551 if max_read_request_operation_count is not None :
552- __body [
553- " max_read_request_operation_count"
554- ] = max_read_request_operation_count
552+ __body ["max_read_request_operation_count" ] = (
553+ max_read_request_operation_count
554+ )
555555 if max_read_request_size is not None :
556556 __body ["max_read_request_size" ] = max_read_request_size
557557 if max_retry_delay is not None :
@@ -561,9 +561,9 @@ async def put_auto_follow_pattern(
561561 if max_write_buffer_size is not None :
562562 __body ["max_write_buffer_size" ] = max_write_buffer_size
563563 if max_write_request_operation_count is not None :
564- __body [
565- " max_write_request_operation_count"
566- ] = max_write_request_operation_count
564+ __body ["max_write_request_operation_count" ] = (
565+ max_write_request_operation_count
566+ )
567567 if max_write_request_size is not None :
568568 __body ["max_write_request_size" ] = max_write_request_size
569569 if read_poll_timeout is not None :
@@ -682,13 +682,13 @@ async def resume_follow(
682682 if max_outstanding_read_requests is not None :
683683 __body ["max_outstanding_read_requests" ] = max_outstanding_read_requests
684684 if max_outstanding_write_requests is not None :
685- __body [
686- " max_outstanding_write_requests"
687- ] = max_outstanding_write_requests
685+ __body ["max_outstanding_write_requests" ] = (
686+ max_outstanding_write_requests
687+ )
688688 if max_read_request_operation_count is not None :
689- __body [
690- " max_read_request_operation_count"
691- ] = max_read_request_operation_count
689+ __body ["max_read_request_operation_count" ] = (
690+ max_read_request_operation_count
691+ )
692692 if max_read_request_size is not None :
693693 __body ["max_read_request_size" ] = max_read_request_size
694694 if max_retry_delay is not None :
@@ -698,9 +698,9 @@ async def resume_follow(
698698 if max_write_buffer_size is not None :
699699 __body ["max_write_buffer_size" ] = max_write_buffer_size
700700 if max_write_request_operation_count is not None :
701- __body [
702- " max_write_request_operation_count"
703- ] = max_write_request_operation_count
701+ __body ["max_write_request_operation_count" ] = (
702+ max_write_request_operation_count
703+ )
704704 if max_write_request_size is not None :
705705 __body ["max_write_request_size" ] = max_write_request_size
706706 if read_poll_timeout is not None :
0 commit comments