[{'Text': '        if raw_file:\n            try:\n                if raw_file.startswith("s3://"):\n                    b, k = s3u.parse_s3_uri(file_url)  # type: ignore[arg-type]\n                    dk = s3u.build_sources_dest_key(operator_id, year, quarter, k.rstrip("/").rsplit("/", 1)[-1] or "file")\n                    final_file_url = s3u.copy_to_sources_bucket(b, k, dk)\n                else:\n                    body, ct = s3u.download_from_url(file_url)  # type: ignore[arg-type]\n                    fn = urlparse(file_url).path.rstrip("/").rsplit("/", 1)[-1] or "download"  # type: ignore[arg-type]\n                    dk = s3u.build_sources_dest_key(operator_id, year, quarter, fn)\n                    final_file_url = s3u.upload_to_sources_bucket(body, ct, dk)\n            except RuntimeError as e:\n                return str(e)\n\n        for s in mongo.find_sources(operator_id, year, quarter):\n            if s.get("type") == type and s.get("url") == web_url and s.get("fileUrl") == final_file_url:\n                return f"Duplicate source (id={mongo._oid_from_doc(s)})"\n\n'}]