You can also use asyncio.to_thread

async def upload_stream(self, stream, bucket_name, key):
   await asyncio.to_thread(self.S3.put_object, Body=stream, Bucket=bucket_name, Key=key)