def _setup_cancel_due_to_duplication()

in mapillary_tools/upload.py [0:0]


def _setup_cancel_due_to_duplication(emitter: uploader.EventEmitter) -> None:
    @emitter.on("upload_start")
    def upload_start(payload: uploader.Progress):
        md5sum = payload["md5sum"]
        if is_uploaded(md5sum):
            sequence_uuid = payload.get("sequence_uuid")
            if sequence_uuid is None:
                basename = os.path.basename(payload.get("import_path", ""))
                LOG.info(
                    f"File {basename} has been uploaded already. Check the upload history at {_history_desc_path(md5sum)}"
                )
            else:
                LOG.info(
                    f"Sequence {sequence_uuid} has been uploaded already. Check the upload history at {_history_desc_path(md5sum)}"
                )
            raise uploader.UploadCancelled()