    async def _clear_multipart_uploads(self, bucket):
        """Remove any partial uploads in the bucket"""
        await asyncio.gather(
            *[
                self._abort_mpu(bucket, upload["Key"], upload["UploadId"])
                for upload in await self._list_multipart_uploads(bucket)
            ]
        )
Remove any partial uploads in the bucket
s3fs/core.py