|
6 | 6 | import json
|
7 | 7 | import logging
|
8 | 8 | import math
|
9 |
| -import os |
10 | 9 | from concurrent.futures import Future, ThreadPoolExecutor
|
11 | 10 | from typing import Generator, Optional, Tuple, Union
|
12 | 11 |
|
@@ -580,21 +579,26 @@ def _get_split_pdf_call_threads(self, form_data: FormData) -> int:
|
580 | 579 | num_threads = int(num_threads_str)
|
581 | 580 | except ValueError:
|
582 | 581 | logger.warning(
|
583 |
| - f"'{PARTITION_FORM_NUM_THREADS_KEY}' is not a valid integer. " |
584 |
| - f"Using default value '{DEFAULT_NUM_THREADS}'.", |
| 582 | + "'%s' is not a valid integer. Using default value '%s'.", |
| 583 | + PARTITION_FORM_NUM_THREADS_KEY, |
| 584 | + DEFAULT_NUM_THREADS, |
585 | 585 | )
|
586 | 586 | return DEFAULT_NUM_THREADS
|
587 | 587 |
|
588 | 588 | if num_threads < 1:
|
589 | 589 | logger.warning(
|
590 |
| - f"'{PARTITION_FORM_NUM_THREADS_KEY}' is less than 1. " |
591 |
| - f"Using the default value ={DEFAULT_NUM_THREADS}.", |
| 590 | + "'%s' is less than 1. Using the default value = %s.", |
| 591 | + PARTITION_FORM_NUM_THREADS_KEY, |
| 592 | + DEFAULT_NUM_THREADS, |
592 | 593 | )
|
593 | 594 | return DEFAULT_NUM_THREADS
|
594 |
| - elif num_threads > MAX_THREADS: |
| 595 | + |
| 596 | + if num_threads > MAX_THREADS: |
595 | 597 | logger.warning(
|
596 |
| - f"'{PARTITION_FORM_NUM_THREADS_KEY}' is greater than {MAX_THREADS}. " |
597 |
| - f"Using the maximum allowed value ={MAX_THREADS}.", |
| 598 | + "'%s' is greater than %s. Using the maximum allowed value = %s.", |
| 599 | + PARTITION_FORM_NUM_THREADS_KEY, |
| 600 | + MAX_THREADS, |
| 601 | + MAX_THREADS, |
598 | 602 | )
|
599 | 603 | return MAX_THREADS
|
600 | 604 |
|
|
0 commit comments