diff --git a/setup.py b/setup.py index 887b31f..6eea387 100644 --- a/setup.py +++ b/setup.py @@ -5,6 +5,6 @@ setup( install_requires=[ 'target-core==0.1.0', - 'boto3==1.26.20' + 'boto3==1.26.82' ] ) diff --git a/src/target_s3_json/s3.py b/src/target_s3_json/s3.py index 03946c9..423d33f 100644 --- a/src/target_s3_json/s3.py +++ b/src/target_s3_json/s3.py @@ -158,7 +158,7 @@ def upload_file(config: Dict[str, Any], file_metadata: Dict) -> None: async def upload_thread(config: Dict[str, Any], file_metadata: Dict) -> Future: return await to_thread( - config['executor'].submit, + *([config['executor'].submit] if config.get('thread_pool', True) else []), upload_file, config, file_metadata)