diff --git a/main.py b/main.py index 35fd3b73aa16ea4c3e7558453f5b4d8ab14b5cb7..a7c916b1c6ae8357dade6e7c4fa3db8e267cddc7 100644 --- a/main.py +++ b/main.py @@ -10,7 +10,7 @@ logging.basicConfig(format="%(asctime)s [%(levelname)s] [%(name)s] %(message)s", logger = logging.getLogger(__name__) from minio import Minio -from minio.error import InvalidResponseError, NoSuchBucket +from minio.error import ResponseError, NoSuchBucket def mirror(src, dst, bucket, tmp_directory): @@ -62,7 +62,7 @@ def mirror(src, dst, bucket, tmp_directory): with open(tmp_file, 'wb') as file_data: for d in data.stream(32*1024): file_data.write(d) - except InvalidResponseError as err: + except ResponseError as err: logger.error(err) try: @@ -72,7 +72,7 @@ def mirror(src, dst, bucket, tmp_directory): logger.debug("MIME type: {0}".format(mime_type)) dst.put_object(bucket, object_name, file_data, file_stat.st_size, content_type=mime_type) - except InvalidResponseError as err: + except ResponseError as err: logger.error(err) else: logger.debug('No object to copy.') @@ -83,7 +83,7 @@ def mirror(src, dst, bucket, tmp_directory): try: for del_err in dst.remove_objects(bucket, object_names_to_rm): logger.error("Deletion Error: {}".format(del_err)) - except InvalidResponseError as err: + except ResponseError as err: logger.error(err) else: logger.debug('No object to remove.') diff --git a/requirements.txt b/requirements.txt index 1df392122754021553debdfb7bad6e5152d5a83b..c7ca6a1e98383b7d94362bb164e712b24da21e4e 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,3 +1,3 @@ -minio +minio==5.0.6 python-magic pyyaml