(self, src_uri, dst_uri, extra_headers=None,
src_size=None, extra_label="")
| 1100 | extra_label, replace_meta=True) |
| 1101 | |
| 1102 | def object_move(self, src_uri, dst_uri, extra_headers=None, |
| 1103 | src_size=None, extra_label=""): |
| 1104 | response_copy = self.object_copy(src_uri, dst_uri, extra_headers, |
| 1105 | src_size, extra_label) |
| 1106 | debug("Object %s copied to %s" % (src_uri, dst_uri)) |
| 1107 | if not response_copy["data"] \ |
| 1108 | or getRootTagName(response_copy["data"]) \ |
| 1109 | in ["CopyObjectResult", "CompleteMultipartUploadResult"]: |
| 1110 | self.object_delete(src_uri) |
| 1111 | debug("Object '%s' deleted", src_uri) |
| 1112 | else: |
| 1113 | warning("Object '%s' NOT deleted because of an unexpected " |
| 1114 | "response data content.", src_uri) |
| 1115 | return response_copy |
| 1116 | |
| 1117 | def object_info(self, uri): |
| 1118 | request = self.create_request("OBJECT_HEAD", uri=uri) |
nothing calls this directly
no test coverage detected