diff --git a/s3_storage_provider.py b/s3_storage_provider.py index 1206020..cbf4000 100644 --- a/s3_storage_provider.py +++ b/s3_storage_provider.py @@ -144,15 +144,14 @@ async def fetch(self, path, file_info): # coroutine returned by `defer_to_threadpool` is used, and therefore # actually run. run_in_background( - self._module_api.defer_to_threadpool( - self._s3_pool, - s3_download_task, - self._get_s3_client(), - self.bucket, - self.prefix + path, - self.extra_args, - d, - ) + self._module_api.defer_to_threadpool, + self._s3_pool, + s3_download_task, + self._get_s3_client(), + self.bucket, + self.prefix + path, + self.extra_args, + d, ) # DO await on `d`, as it will resolve once a connection to S3 has been