fast-DreamBooth.ipynb

{
 "cells": [
  {
   "attachments": {},
   "cell_type": "markdown",
   "metadata": {
    "id": "qEsNHTtVlbkV"
   },
   "source": [
    "# **Colab Pro notebook from https://github.com/TheLastBen/fast-stable-diffusion** *Alternatives : [Paperspace](https://console.paperspace.com/github/TheLastBen/PPS?machine=Free-GPU)*"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "id": "A4Bae3VP6UsE"
   },
   "outputs": [],
   "source": [
    "from google.colab import drive\n",
    "drive.mount('/content/gdrive')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "QyvcqeiL65Tj"
   },
   "outputs": [],
   "source": [
    "#@markdown # Dependencies\n",
    "\n",
    "from IPython.utils import capture\n",
    "import time\n",
    "import os\n",
    "\n",
    "print('\u001b[1;32mInstalling dependencies...')\n",
    "with capture.capture_output() as cap:\n",
    "    os.chdir('/content')\n",
    "    !pip uninstall diffusers -qq -y\n",
    "    !pip install -qq --no-deps accelerate==0.12.0\n",
    "    !rm -r /usr/local/lib/python3.10/dist-packages/wandb*\n",
    "    !wget -q -i https://raw.githubusercontent.com/TheLastBen/fast-stable-diffusion/main/Dependencies/dbdeps.txt\n",
    "    !dpkg -i *.deb\n",
    "    !tar -C / --zstd -xf gcolabdeps.tar.zst\n",
    "    !rm *.deb | rm *.zst | rm *.txt\n",
    "    !git clone -q --depth 1 --branch main https://github.com/TheLastBen/diffusers\n",
    "    !pip install gradio==3.16.2 --no-deps -qq\n",
    "    !rm -r /usr/local/lib/python3.10/dist-packages/google/_upb\n",
    "\n",
    "    if not os.path.exists('gdrive/MyDrive/sd/libtcmalloc/libtcmalloc_minimal.so.4'):\n",
    "        %env CXXFLAGS=-std=c++14\n",
    "        !wget -q https://github.com/gperftools/gperftools/releases/download/gperftools-2.5/gperftools-2.5.tar.gz && tar zxf gperftools-2.5.tar.gz && mv gperftools-2.5 gperftools\n",
    "        !wget -q https://github.com/TheLastBen/fast-stable-diffusion/raw/main/AUTOMATIC1111_files/Patch\n",
    "        %cd /content/gperftools  \n",
    "        !patch -p1 < /content/Patch\n",
    "        !./configure --enable-minimal --enable-libunwind --enable-frame-pointers --enable-dynamic-sized-delete-support --enable-sized-delete --enable-emergency-malloc; make -j4\n",
    "        !mkdir -p /content/gdrive/MyDrive/sd/libtcmalloc && cp .libs/libtcmalloc*.so* /content/gdrive/MyDrive/sd/libtcmalloc\n",
    "        %env LD_PRELOAD=/content/gdrive/MyDrive/sd/libtcmalloc/libtcmalloc_minimal.so.4\n",
    "        %cd /content\n",
    "        !rm *.tar.gz Patch && rm -r /content/gperftools\n",
    "    else:\n",
    "        %env LD_PRELOAD=/content/gdrive/MyDrive/sd/libtcmalloc/libtcmalloc_minimal.so.4\n",
    "\n",
    "    os.environ['TF_CPP_MIN_LOG_LEVEL'] = '3'\n",
    "    os.environ['PYTHONWARNINGS'] = 'ignore'\n",
    "    !sed -i 's@raise AttributeError(f\"module {module!r} has no attribute {name!r}\")@@g' /usr/local/lib/python3.10/dist-packages/jax/_src/deprecations.py\n",
    "\n",
    "print('\u001b[1;32mDone, proceed')"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {
    "id": "R3SsbIlxw66N"
   },
   "source": [
    "# Model Download"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "O3KHGKqyeJp9"
   },
   "outputs": [],
   "source": [
    "import os\n",
    "import time\n",
    "from IPython.utils import capture\n",
    "from IPython.display import clear_output\n",
    "import wget\n",
    "from subprocess import check_output\n",
    "import urllib.request\n",
    "import requests\n",
    "import base64\n",
    "from gdown.download import get_url_from_gdrive_confirmation\n",
    "from urllib.parse import urlparse, parse_qs, unquote\n",
    "from urllib.request import urlopen, Request\n",
    "import re\n",
    "\n",
    "def getsrc(url):\n",
    "    parsed_url = urlparse(url)\n",
    "    if parsed_url.netloc == 'civitai.com':\n",
    "        src='civitai'\n",
    "    elif parsed_url.netloc == 'drive.google.com':\n",
    "        src='gdrive'\n",
    "    elif parsed_url.netloc == 'huggingface.co':\n",
    "        src='huggingface'\n",
    "    else:\n",
    "        src='others'\n",
    "    return src\n",
    "\n",
    "\n",
    "\n",
    "def get_name(url, gdrive):\n",
    "    if not gdrive:\n",
    "        response = requests.get(url, allow_redirects=False)\n",
    "        if \"Location\" in response.headers:\n",
    "            redirected_url = response.headers[\"Location\"]\n",
    "            quer = parse_qs(urlparse(redirected_url).query)\n",
    "            if \"response-content-disposition\" in quer:\n",
    "                disp_val = quer[\"response-content-disposition\"][0].split(\";\")\n",
    "                for vals in disp_val:\n",
    "                    if vals.strip().startswith(\"filename=\"):\n",
    "                        filenm=unquote(vals.split(\"=\", 1)[1].strip())\n",
    "                        return filenm.replace(\"\\\"\",\"\")\n",
    "    else:\n",
    "        headers = {\"User-Agent\": \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_10_1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/39.0.2171.95 Safari/537.36\"}\n",
    "        lnk=\"https://drive.google.com/uc?id={id}&export=download\".format(id=url[url.find(\"/d/\")+3:url.find(\"/view\")])\n",
    "        res = requests.session().get(lnk, headers=headers, stream=True, verify=True)\n",
    "        res = requests.session().get(get_url_from_gdrive_confirmation(res.text), headers=headers, stream=True, verify=True)\n",
    "        content_disposition = six.moves.urllib_parse.unquote(res.headers[\"Content-Disposition\"])\n",
    "        filenm = re.search('attachment; filename=\"(.*?)\"', content_disposition).groups()[0]\n",
    "        return filenm\n",
    "\n",
    "#@markdown - Skip this cell if you are loading a previous session that contains a trained model.\n",
    "\n",
    "#@markdown ---\n",
    "\n",
    "Model_Version = \"1.5\" #@param [ \"1.5\", \"V2.1-512px\", \"V2.1-768px\"]\n",
    "\n",
    "#@markdown - Choose which version to finetune.\n",
    "\n",
    "with capture.capture_output() as cap: \n",
    "  os.chdir('/content')\n",
    "\n",
    "#@markdown ---\n",
    "\n",
    "Path_to_HuggingFace= \"\" #@param {type:\"string\"}\n",
    "\n",
    "#@markdown - Load and finetune a model from Hugging Face, use the format \"profile/model\" like : runwayml/stable-diffusion-v1-5\n",
    "#@markdown - If the custom model is private or requires a token, create token.txt containing the token in \"Fast-Dreambooth\" folder in your gdrive.\n",
    "\n",
    "MODEL_PATH = \"\" #@param {type:\"string\"}\n",
    "\n",
    "MODEL_LINK = \"\" #@param {type:\"string\"}\n",
    "\n",
    "\n",
    "if os.path.exists('/content/gdrive/MyDrive/Fast-Dreambooth/token.txt'):\n",
    "  with open(\"/content/gdrive/MyDrive/Fast-Dreambooth/token.txt\") as f:\n",
    "     token = f.read()\n",
    "  authe=f'https://USER:{token}@'\n",
    "else:\n",
    "  authe=\"https://\"\n",
    "\n",
    "def downloadmodel():\n",
    "\n",
    "  if os.path.exists('/content/stable-diffusion-v1-5'):\n",
    "    !rm -r /content/stable-diffusion-v1-5\n",
    "  clear_output()\n",
    "\n",
    "  os.chdir('/content')\n",
    " \n",
    "  print(\"\u001b[1;32mDownloading the model...\")\n",
    "  !wget -q \"https://huggingface.co/runwayml/stable-diffusion-v1-5/resolve/main/v1-5-pruned-emaonly.safetensors\" -O model.safetensors\n",
    "\n",
    "  if os.path.exists('/content/model.safetensors'):\n",
    "      !wget -q -O config.yaml https://github.com/CompVis/stable-diffusion/raw/main/configs/stable-diffusion/v1-inference.yaml\n",
    "      clear_output()\n",
    "      !python /content/diffusers/scripts/convert_original_stable_diffusion_to_diffusers.py --checkpoint_path /content/model.safetensors --dump_path /content/stable-diffusion-v1-5 --original_config_file config.yaml --from_safetensors\n",
    "      !rm config.yaml\n",
    "      clear_output()\n",
    "      os.chdir('/content/stable-diffusion-v1-5')\n",
    "      !wget -q -O vae/diffusion_pytorch_model.bin https://huggingface.co/stabilityai/sd-vae-ft-mse/resolve/main/diffusion_pytorch_model.bin\n",
    "      !rm model_index.json\n",
    "      clear_output()\n",
    "      time.sleep(1)    \n",
    "      wget.download('https://raw.githubusercontent.com/TheLastBen/fast-stable-diffusion/main/Dreambooth/model_index.json')\n",
    "      os.chdir('/content')\n",
    "\n",
    "\n",
    "def newdownloadmodel():\n",
    "\n",
    "  os.chdir('/content')\n",
    "  clear_output()\n",
    "  !mkdir /content/stable-diffusion-v2-768\n",
    "  os.chdir('/content/stable-diffusion-v2-768')\n",
    "  !git config --global init.defaultBranch main\n",
    "  !git init\n",
    "  !git lfs install --system --skip-repo\n",
    "  !git remote add -f origin  \"https://huggingface.co/stabilityai/stable-diffusion-2-1\"\n",
    "  !git config core.sparsecheckout true\n",
    "  !echo -e \"scheduler\\ntext_encoder\\ntokenizer\\nunet\\nvae\\nfeature_extractor\\nmodel_index.json\\n!*.safetensors\\n!*.fp16.bin\" > .git/info/sparse-checkout\n",
    "  !git pull origin main\n",
    "  !rm -r /content/stable-diffusion-v2-768/.git\n",
    "  os.chdir('/content')\n",
    "  clear_output()\n",
    "  print('\u001b[1;32mDONE !')\n",
    "\n",
    "\n",
    "def newdownloadmodelb():\n",
    "\n",
    "  os.chdir('/content')\n",
    "  clear_output()\n",
    "  !mkdir /content/stable-diffusion-v2-512\n",
    "  os.chdir('/content/stable-diffusion-v2-512')\n",
    "  !git config --global init.defaultBranch main\n",
    "  !git init\n",
    "  !git lfs install --system --skip-repo\n",
    "  !git remote add -f origin  \"https://huggingface.co/stabilityai/stable-diffusion-2-1-base\"\n",
    "  !git config core.sparsecheckout true\n",
    "  !echo -e \"scheduler\\ntext_encoder\\ntokenizer\\nunet\\nvae\\nfeature_extractor\\nmodel_index.json\\n!*.safetensors\\n!*.fp16.bin\" > .git/info/sparse-checkout\n",
    "  !git pull origin main\n",
    "  !rm -r /content/stable-diffusion-v2-512/.git\n",
    "  os.chdir('/content')\n",
    "  clear_output()\n",
    "  print('\u001b[1;32mDONE !')\n",
    "\n",
    "\n",
    "if Path_to_HuggingFace != \"\":\n",
    "  if authe==\"https://\":\n",
    "    textenc= f\"{authe}huggingface.co/{Path_to_HuggingFace}/resolve/main/text_encoder/pytorch_model.bin\"\n",
    "    txtenc_size=urllib.request.urlopen(textenc).info().get('Content-Length', None)\n",
    "  else:\n",
    "    textenc= f\"https://huggingface.co/{Path_to_HuggingFace}/resolve/main/text_encoder/pytorch_model.bin\"\n",
    "    req=urllib.request.Request(textenc)\n",
    "    req.add_header('Authorization', f'Bearer {token}')\n",
    "    txtenc_size=urllib.request.urlopen(req).info().get('Content-Length', None)\n",
    "  if int(txtenc_size)> 670000000 :\n",
    "    if os.path.exists('/content/stable-diffusion-custom'):\n",
    "      !rm -r /content/stable-diffusion-custom\n",
    "    clear_output()\n",
    "    os.chdir('/content')\n",
    "    clear_output()\n",
    "    print(\"\u001b[1;32mV2\")\n",
    "    !mkdir /content/stable-diffusion-custom\n",
    "    os.chdir('/content/stable-diffusion-custom')\n",
    "    !git config --global init.defaultBranch main\n",
    "    !git init\n",
    "    !git lfs install --system --skip-repo\n",
    "    !git remote add -f origin  \"{authe}huggingface.co/{Path_to_HuggingFace}\"\n",
    "    !git config core.sparsecheckout true\n",
    "    !echo -e \"scheduler\\ntext_encoder\\ntokenizer\\nunet\\nvae\\nfeature_extractor\\nmodel_index.json\\n!*.safetensors\" > .git/info/sparse-checkout\n",
    "    !git pull origin main\n",
    "    if os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "      !rm -r /content/stable-diffusion-custom/.git\n",
    "      os.chdir('/content')\n",
    "      MODEL_NAME=\"/content/stable-diffusion-custom\"\n",
    "      clear_output()\n",
    "      print('\u001b[1;32mDONE !')\n",
    "    else:\n",
    "      while not os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "            print('\u001b[1;31mCheck the link you provided')\n",
    "            time.sleep(5)\n",
    "  else:\n",
    "    if os.path.exists('/content/stable-diffusion-custom'):\n",
    "      !rm -r /content/stable-diffusion-custom\n",
    "    clear_output()\n",
    "    os.chdir('/content')\n",
    "    clear_output()\n",
    "    print(\"\u001b[1;32mV1\")\n",
    "    !mkdir /content/stable-diffusion-custom\n",
    "    os.chdir('/content/stable-diffusion-custom')\n",
    "    !git init\n",
    "    !git lfs install --system --skip-repo\n",
    "    !git remote add -f origin  \"{authe}huggingface.co/{Path_to_HuggingFace}\"\n",
    "    !git config core.sparsecheckout true\n",
    "    !echo -e \"scheduler\\ntext_encoder\\ntokenizer\\nunet\\nvae\\nmodel_index.json\\n!*.safetensors\" > .git/info/sparse-checkout\n",
    "    !git pull origin main\n",
    "    if os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "      !rm -r /content/stable-diffusion-custom/.git\n",
    "      !rm model_index.json\n",
    "      time.sleep(1)\n",
    "      wget.download('https://raw.githubusercontent.com/TheLastBen/fast-stable-diffusion/main/Dreambooth/model_index.json')\n",
    "      os.chdir('/content')\n",
    "      MODEL_NAME=\"/content/stable-diffusion-custom\"\n",
    "      clear_output()\n",
    "      print('\u001b[1;32mDONE !')\n",
    "    else:\n",
    "      while not os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "            print('\u001b[1;31mCheck the link you provided')\n",
    "            time.sleep(5)\n",
    "\n",
    "elif MODEL_PATH !=\"\":\n",
    "\n",
    "  modelname=os.path.basename(MODEL_PATH)\n",
    "  sftnsr=\"\"\n",
    "  if modelname.split('.')[-1]=='safetensors':\n",
    "    sftnsr=\"--from_safetensors\"  \n",
    "\n",
    "  %cd /content\n",
    "  clear_output()\n",
    "  if os.path.exists(str(MODEL_PATH)):\n",
    "    wget.download('https://github.com/TheLastBen/fast-stable-diffusion/raw/main/Dreambooth/det.py')\n",
    "    print('\u001b[1;33mDetecting model version...')\n",
    "    Custom_Model_Version=check_output('python det.py '+sftnsr+' --MODEL_PATH '+str(MODEL_PATH), shell=True).decode('utf-8').replace('\\n', '')\n",
    "    clear_output()\n",
    "    print('\u001b[1;32m'+Custom_Model_Version+' Detected')    \n",
    "    !rm det.py\n",
    "    if Custom_Model_Version=='1.5':      \n",
    "      !wget -q -O config.yaml https://github.com/CompVis/stable-diffusion/raw/main/configs/stable-diffusion/v1-inference.yaml\n",
    "      !python /content/diffusers/scripts/convert_original_stable_diffusion_to_diffusers.py --checkpoint_path \"$MODEL_PATH\" --dump_path stable-diffusion-custom --original_config_file config.yaml $sftnsr\n",
    "      !rm /content/config.yaml\n",
    "\n",
    "    elif Custom_Model_Version=='V2.1-512px':\n",
    "      !wget -q -O convertodiff.py https://raw.githubusercontent.com/TheLastBen/fast-stable-diffusion/main/Dreambooth/convertodiffv2.py\n",
    "      !python /content/convertodiff.py \"$MODEL_PATH\" /content/stable-diffusion-custom --v2 --reference_model stabilityai/stable-diffusion-2-1-base $sftnsr\n",
    "      !rm /content/convertodiff.py\n",
    "\n",
    "    elif Custom_Model_Version=='V2.1-768px':\n",
    "      !wget -q -O convertodiff.py https://github.com/TheLastBen/fast-stable-diffusion/raw/main/Dreambooth/convertodiffv2-768.py\n",
    "      !python /content/convertodiff.py \"$MODEL_PATH\" /content/stable-diffusion-custom --v2 --reference_model stabilityai/stable-diffusion-2-1 $sftnsr\n",
    "      !rm /content/convertodiff.py\n",
    "\n",
    "\n",
    "    if os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "      clear_output()\n",
    "      MODEL_NAME=\"/content/stable-diffusion-custom\"\n",
    "      print('\u001b[1;32mDONE !')\n",
    "    else:\n",
    "      !rm -r /content/stable-diffusion-custom\n",
    "      while not os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "        print('\u001b[1;31mConversion error')\n",
    "        time.sleep(5)\n",
    "  else:\n",
    "    while not os.path.exists(str(MODEL_PATH)):\n",
    "       print('\u001b[1;31mWrong path, use the colab file explorer to copy the path')\n",
    "       time.sleep(5)\n",
    "\n",
    "elif MODEL_LINK !=\"\":\n",
    "    os.chdir('/content')\n",
    "\n",
    "    src=getsrc(MODEL_LINK)\n",
    "\n",
    "    if src=='civitai':\n",
    "       modelname=get_name(str(MODEL_LINK), False)\n",
    "    elif src=='gdrive':\n",
    "       modelname=get_name(str(MODEL_LINK), True)\n",
    "    else:\n",
    "       modelname=os.path.basename(str(MODEL_LINK))\n",
    "\n",
    "    sftnsr=\"\"\n",
    "    if modelname.split('.')[-1]!='safetensors':\n",
    "      modelnm=\"model.ckpt\"\n",
    "    else:\n",
    "      modelnm=\"model.safetensors\"\n",
    "      sftnsr=\"--from_safetensors\"\n",
    "    \n",
    "    !gdown --fuzzy \"$MODEL_LINK\" -O $modelnm\n",
    "\n",
    "    if os.path.exists(modelnm):\n",
    "      if os.path.getsize(modelnm) > 1810671599:\n",
    "        wget.download('https://github.com/TheLastBen/fast-stable-diffusion/raw/main/Dreambooth/det.py')\n",
    "        print('\u001b[1;33mDetecting model version...')\n",
    "        Custom_Model_Version=check_output('python det.py '+sftnsr+' --MODEL_PATH '+modelnm, shell=True).decode('utf-8').replace('\\n', '')\n",
    "        clear_output()\n",
    "        print('\u001b[1;32m'+Custom_Model_Version+' Detected') \n",
    "        !rm det.py\n",
    "        if Custom_Model_Version=='1.5':\n",
    "          !wget -q -O config.yaml https://github.com/CompVis/stable-diffusion/raw/main/configs/stable-diffusion/v1-inference.yaml\n",
    "          !python /content/diffusers/scripts/convert_original_stable_diffusion_to_diffusers.py --checkpoint_path $modelnm --dump_path stable-diffusion-custom --original_config_file config.yaml $sftnsr\n",
    "          !rm config.yaml\n",
    "\n",
    "        elif Custom_Model_Version=='V2.1-512px':\n",
    "          !wget -q -O convertodiff.py https://raw.githubusercontent.com/TheLastBen/fast-stable-diffusion/main/Dreambooth/convertodiffv2.py\n",
    "          !python /content/convertodiff.py $modelnm /content/stable-diffusion-custom --v2 --reference_model stabilityai/stable-diffusion-2-1-base $sftnsr\n",
    "          !rm convertodiff.py\n",
    "\n",
    "        elif Custom_Model_Version=='V2.1-768px':\n",
    "          !wget -q -O convertodiff.py https://github.com/TheLastBen/fast-stable-diffusion/raw/main/Dreambooth/convertodiffv2-768.py\n",
    "          !python /content/convertodiff.py $modelnm /content/stable-diffusion-custom --v2 --reference_model stabilityai/stable-diffusion-2-1 $sftnsr\n",
    "          !rm convertodiff.py\n",
    "\n",
    "\n",
    "        if os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "          clear_output()\n",
    "          MODEL_NAME=\"/content/stable-diffusion-custom\"\n",
    "          print('\u001b[1;32mDONE !')\n",
    "        else:\n",
    "          !rm -r stable-diffusion-custom\n",
    "          !rm $modelnm\n",
    "          while not os.path.exists('/content/stable-diffusion-custom/unet/diffusion_pytorch_model.bin'):\n",
    "            print('\u001b[1;31mConversion error')\n",
    "            time.sleep(5)\n",
    "      else:\n",
    "        while os.path.getsize(modelnm) < 1810671599:\n",
    "           print('\u001b[1;31mWrong link, check that the link is valid')\n",
    "           time.sleep(5)\n",
    "\n",
    "else:\n",
    "  if Model_Version==\"1.5\":\n",
    "    if not os.path.exists('/content/stable-diffusion-v1-5/unet'):\n",
    "      downloadmodel()\n",
    "      MODEL_NAME=\"/content/stable-diffusion-v1-5\"\n",
    "      print(\"\u001b[1;32mv1.5 model downloaded\")\n",
    "    else:\n",
    "      MODEL_NAME=\"/content/stable-diffusion-v1-5\"\n",
    "      print(\"\u001b[1;32mThe v1.5 model already exists, using this model.\")\n",
    "  elif Model_Version==\"V2.1-512px\":\n",
    "    if not os.path.exists('/content/stable-diffusion-v2-512'):\n",
    "      newdownloadmodelb()\n",
    "      MODEL_NAME=\"/content/stable-diffusion-v2-512\"\n",
    "    else:\n",
    "      MODEL_NAME=\"/content/stable-diffusion-v2-512\"\n",
    "      print(\"\u001b[1;32mThe v2-512px model already exists, using this model.\")\n",
    "  elif Model_Version==\"V2.1-768px\":\n",
    "    if not os.path.exists('/content/stable-diffusion-v2-768'):\n",
    "      newdownloadmodel()\n",
    "      MODEL_NAME=\"/content/stable-diffusion-v2-768\"\n",
    "    else:\n",
    "      MODEL_NAME=\"/content/stable-diffusion-v2-768\"\n",
    "      print(\"\u001b[1;32mThe v2-768px model already exists, using this model.\")"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {
    "id": "0tN76Cj5P3RL"
   },
   "source": [
    "# Dreambooth"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "A1B299g-_VJo"
   },
   "outputs": [],
   "source": [
    "import os\n",
    "from IPython.display import clear_output\n",
    "from IPython.utils import capture\n",
    "from os import listdir\n",
    "from os.path import isfile\n",
    "from subprocess import check_output\n",
    "import wget\n",
    "import time\n",
    "\n",
    "#@markdown #Create/Load a Session\n",
    "\n",
    "try:\n",
    "  MODEL_NAME\n",
    "  pass\n",
    "except:\n",
    "  MODEL_NAME=\"\"\n",
    "  \n",
    "PT=\"\"\n",
    "\n",
    "Session_Name = \"\" #@param{type: 'string'}\n",
    "while Session_Name==\"\":\n",
    "  print('\u001b[1;31mInput the Session Name:') \n",
    "  Session_Name=input('')\n",
    "Session_Name=Session_Name.replace(\" \",\"_\")\n",
    "\n",
    "#@markdown - Enter the session name, it if it exists, it will load it, otherwise it'll create an new session.\n",
    "\n",
    "Session_Link_optional = \"\" #@param{type: 'string'}\n",
    "\n",
    "#@markdown - Import a session from another gdrive, the shared gdrive link must point to the specific session's folder that contains the trained CKPT, remove any intermediary CKPT if any.\n",
    "\n",
    "WORKSPACE='/content/gdrive/MyDrive/Fast-Dreambooth'\n",
    "\n",
    "if Session_Link_optional !=\"\":\n",
    "  print('\u001b[1;32mDownloading session...')\n",
    "  with capture.capture_output() as cap:\n",
    "    %cd /content\n",
    "    if not os.path.exists(str(WORKSPACE+'/Sessions')):\n",
    "      %mkdir -p $WORKSPACE'/Sessions'\n",
    "      time.sleep(1)\n",
    "    %cd $WORKSPACE'/Sessions'\n",
    "    !gdown --folder --remaining-ok -O $Session_Name  $Session_Link_optional\n",
    "    %cd $Session_Name\n",
    "    !rm -r instance_images\n",
    "    !unzip instance_images.zip\n",
    "    !rm -r captions\n",
    "    !unzip captions.zip\n",
    "    %cd /content\n",
    "\n",
    "\n",
    "INSTANCE_NAME=Session_Name\n",
    "OUTPUT_DIR=\"/content/models/\"+Session_Name\n",
    "SESSION_DIR=WORKSPACE+'/Sessions/'+Session_Name\n",
    "INSTANCE_DIR=SESSION_DIR+'/instance_images'\n",
    "CAPTIONS_DIR=SESSION_DIR+'/captions'\n",
    "MDLPTH=str(SESSION_DIR+\"/\"+Session_Name+'.ckpt')\n",
    "\n",
    "if os.path.exists(str(SESSION_DIR)):\n",
    "  mdls=[ckpt for ckpt in listdir(SESSION_DIR) if ckpt.split(\".\")[-1]==\"ckpt\"]\n",
    "  if not os.path.exists(MDLPTH) and '.ckpt' in str(mdls):  \n",
    "    \n",
    "    def f(n):\n",
    "      k=0\n",
    "      for i in mdls:\n",
    "        if k==n:\n",
    "          !mv \"$SESSION_DIR/$i\" $MDLPTH\n",
    "        k=k+1\n",
    "\n",
    "    k=0\n",
    "    print('\u001b[1;33mNo final checkpoint model found, select which intermediary checkpoint to use, enter only the number, (000 to skip):\\n\u001b[1;34m')\n",
    "\n",
    "    for i in mdls:\n",
    "      print(str(k)+'- '+i)\n",
    "      k=k+1\n",
    "    n=input()\n",
    "    while int(n)>k-1:\n",
    "      n=input()\n",
    "    if n!=\"000\":\n",
    "      f(int(n))\n",
    "      print('\u001b[1;32mUsing the model '+ mdls[int(n)]+\" ...\")\n",
    "      time.sleep(2)\n",
    "    else:\n",
    "      print('\u001b[1;32mSkipping the intermediary checkpoints.')\n",
    "    del n\n",
    "\n",
    "with capture.capture_output() as cap:\n",
    "  %cd /content\n",
    "  resume=False\n",
    "\n",
    "if os.path.exists(str(SESSION_DIR)) and not os.path.exists(MDLPTH):\n",
    "  print('\u001b[1;32mLoading session with no previous model, using the original model or the custom downloaded model')\n",
    "  if MODEL_NAME==\"\":\n",
    "    print('\u001b[1;31mNo model found, use the \"Model Download\" cell to download a model.')\n",
    "  else:\n",
    "    print('\u001b[1;32mSession Loaded, proceed to uploading instance images')\n",
    "\n",
    "elif os.path.exists(MDLPTH):\n",
    "  print('\u001b[1;32mSession found, loading the trained model ...')\n",
    "  wget.download('https://github.com/TheLastBen/fast-stable-diffusion/raw/main/Dreambooth/det.py')\n",
    "  print('\u001b[1;33mDetecting model version...')\n",
    "  Model_Version=check_output('python det.py --MODEL_PATH '+MDLPTH, shell=True).decode('utf-8').replace('\\n', '')\n",
    "  clear_output()\n",
    "  print('\u001b[1;32m'+Model_Version+' Detected') \n",
    "  !rm det.py  \n",
    "  if Model_Version=='1.5':\n",
    "    !wget -q -O config.yaml https://github.com/CompVis/stable-diffusion/raw/main/configs/stable-diffusion/v1-inference.yaml\n",
    "    print('\u001b[1;32mSession found, loading the trained model ...')\n",
    "    !python /content/diffusers/scripts/convert_original_stable_diffusion_to_diffusers.py --checkpoint_path $MDLPTH --dump_path \"$OUTPUT_DIR\" --original_config_file config.yaml\n",
    "    !rm /content/config.yaml\n",
    "\n",
    "  elif Model_Version=='V2.1-512px':\n",
    "    !wget -q -O convertodiff.py https://raw.githubusercontent.com/TheLastBen/fast-stable-diffusion/main/Dreambooth/convertodiffv2.py\n",
    "    print('\u001b[1;32mSession found, loading the trained model ...')\n",
    "    !python /content/convertodiff.py \"$MDLPTH\" \"$OUTPUT_DIR\" --v2 --reference_model stabilityai/stable-diffusion-2-1-base\n",
    "    !rm /content/convertodiff.py\n",
    "\n",
    "  elif Model_Version=='V2.1-768px':\n",
    "    !wget -q -O convertodiff.py https://github.com/TheLastBen/fast-stable-diffusion/raw/main/Dreambooth/convertodiffv2-768.py\n",
    "    print('\u001b[1;32mSession found, loading the trained model ...')\n",
    "    !python /content/convertodiff.py \"$MDLPTH\" \"$OUTPUT_DIR\" --v2 --reference_model stabilityai/stable-diffusion-2-1\n",
    "    !rm /content/convertodiff.py\n",
    "  \n",
    "  \n",
    "  if os.path.exists(OUTPUT_DIR+'/unet/diffusion_pytorch_model.bin'):\n",
    "    resume=True\n",
    "    clear_output()\n",
    "    print('\u001b[1;32mSession loaded.')\n",
    "  else:     \n",
    "    if not os.path.exists(OUTPUT_DIR+'/unet/diffusion_pytorch_model.bin'):\n",
    "      print('\u001b[1;31mConversion error, if the error persists, remove the CKPT file from the current session folder')\n",
    "\n",
    "elif not os.path.exists(str(SESSION_DIR)):\n",
    "    %mkdir -p \"$INSTANCE_DIR\"\n",
    "    print('\u001b[1;32mCreating session...')\n",
    "    if MODEL_NAME==\"\":\n",
    "      print('\u001b[1;31mNo model found, use the \"Model Download\" cell to download a model.')\n",
    "    else:\n",
    "      print('\u001b[1;32mSession created, proceed to uploading instance images')\n",
    "\n",
    "    #@markdown\n",
    "\n",
    "    #@markdown # The most important step is to rename the instance pictures of each subject to a unique unknown identifier, example :\n",
    "    #@markdown - If you have 10 pictures of yourself, simply select them all and rename only one to the chosen identifier for example : phtmejhn, the files would be : phtmejhn (1).jpg, phtmejhn (2).png ....etc then upload them, do the same for other people or objects with a different identifier, and that's it.\n",
    "    #@markdown - Checkout this example : https://i.imgur.com/d2lD3rz.jpeg"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "LC4ukG60fgMy"
   },
   "outputs": [],
   "source": [
    "import shutil\n",
    "from google.colab import files\n",
    "import time\n",
    "from PIL import Image\n",
    "from tqdm import tqdm\n",
    "import ipywidgets as widgets\n",
    "from io import BytesIO\n",
    "import wget\n",
    "\n",
    "with capture.capture_output() as cap:\n",
    "  %cd /content\n",
    "  if not os.path.exists(\"/content/smart_crop.py\"):\n",
    "    wget.download('https://raw.githubusercontent.com/TheLastBen/fast-stable-diffusion/main/Dreambooth/smart_crop.py')\n",
    "  from smart_crop import *\n",
    "\n",
    "#@markdown #Instance Images\n",
    "#@markdown ----\n",
    "\n",
    "#@markdown\n",
    "#@markdown - Run the cell to upload the instance pictures.\n",
    "#@markdown - You can add `external captions` in txt files by simply giving each txt file the same name as the instance image, for example dikgur (1).jpg and dikgur (1).txt, and upload them here, to use the external captions, check the box \"external_captions\" in the training cell. `All the images must have one same extension` jpg or png or....etc\n",
    "\n",
    "Remove_existing_instance_images= True #@param{type: 'boolean'}\n",
    "#@markdown - Uncheck the box to keep the existing instance images.\n",
    "\n",
    "if Remove_existing_instance_images:\n",
    "  if os.path.exists(str(INSTANCE_DIR)):\n",
    "    !rm -r \"$INSTANCE_DIR\"\n",
    "  if os.path.exists(str(CAPTIONS_DIR)):\n",
    "    !rm -r \"$CAPTIONS_DIR\"\n",
    "\n",
    "if not os.path.exists(str(INSTANCE_DIR)):\n",
    "  %mkdir -p \"$INSTANCE_DIR\"\n",
    "if not os.path.exists(str(CAPTIONS_DIR)):\n",
    "  %mkdir -p \"$CAPTIONS_DIR\"\n",
    "\n",
    "if os.path.exists(INSTANCE_DIR+\"/.ipynb_checkpoints\"):\n",
    "  %rm -r $INSTANCE_DIR\"/.ipynb_checkpoints\"\n",
    "\n",
    "\n",
    "IMAGES_FOLDER_OPTIONAL=\"\" #@param{type: 'string'}\n",
    "\n",
    "#@markdown - If you prefer to specify directly the folder of the pictures instead of uploading, this will add the pictures to the existing (if any) instance images. Leave EMPTY to upload.\n",
    "\n",
    "Smart_Crop_images= True #@param{type: 'boolean'}\n",
    "Crop_size = 512 #@param [\"512\", \"576\", \"640\", \"704\", \"768\", \"832\", \"896\", \"960\", \"1024\"] {type:\"raw\"}\n",
    "\n",
    "#@markdown - Smart crop the images without manual intervention.\n",
    "\n",
    "while IMAGES_FOLDER_OPTIONAL !=\"\" and not os.path.exists(str(IMAGES_FOLDER_OPTIONAL)):\n",
    "  print('\u001b[1;31mThe image folder specified does not exist, use the colab file explorer to copy the path :')\n",
    "  IMAGES_FOLDER_OPTIONAL=input('')\n",
    "\n",
    "if IMAGES_FOLDER_OPTIONAL!=\"\":\n",
    "  if os.path.exists(IMAGES_FOLDER_OPTIONAL+\"/.ipynb_checkpoints\"):\n",
    "    %rm -r \"$IMAGES_FOLDER_OPTIONAL\"\"/.ipynb_checkpoints\"\n",
    "\n",
    "  with capture.capture_output() as cap:\n",
    "    !mv $IMAGES_FOLDER_OPTIONAL/*.txt $CAPTIONS_DIR\n",
    "  if Smart_Crop_images:\n",
    "    for filename in tqdm(os.listdir(IMAGES_FOLDER_OPTIONAL), bar_format='  |{bar:15}| {n_fmt}/{total_fmt} Uploaded'):\n",
    "      extension = filename.split(\".\")[-1]\n",
    "      identifier=filename.split(\".\")[0]\n",
    "      new_path_with_file = os.path.join(INSTANCE_DIR, filename)\n",
    "      file = Image.open(IMAGES_FOLDER_OPTIONAL+\"/\"+filename)\n",
    "      width, height = file.size\n",
    "      if file.size !=(Crop_size, Crop_size):\n",
    "        image=crop_image(file, Crop_size)\n",
    "        if extension.upper()==\"JPG\" or extension.upper()==\"jpg\":\n",
    "            image[0] = image[0].convert(\"RGB\")\n",
    "            image[0].save(new_path_with_file, format=\"JPEG\", quality = 100)\n",
    "        else:\n",
    "            image[0].save(new_path_with_file, format=extension.upper())\n",
    "      else:\n",
    "        !cp \"$IMAGES_FOLDER_OPTIONAL/$filename\" \"$INSTANCE_DIR\"\n",
    "\n",
    "  else:\n",
    "    for filename in tqdm(os.listdir(IMAGES_FOLDER_OPTIONAL), bar_format='  |{bar:15}| {n_fmt}/{total_fmt} Uploaded'):\n",
    "      %cp -r \"$IMAGES_FOLDER_OPTIONAL/$filename\" \"$INSTANCE_DIR\"\n",
    "\n",
    "  print('\\n\u001b[1;32mDone, proceed to the next cell')\n",
    "\n",
    "\n",
    "elif IMAGES_FOLDER_OPTIONAL ==\"\":\n",
    "  up=\"\"\n",
    "  uploaded = files.upload()\n",
    "  for filename in uploaded.keys():\n",
    "    if filename.split(\".\")[-1]==\"txt\":\n",
    "      shutil.move(filename, CAPTIONS_DIR)\n",
    "    up=[filename for filename in uploaded.keys() if filename.split(\".\")[-1]!=\"txt\"]\n",
    "  if Smart_Crop_images:\n",
    "    for filename in tqdm(up, bar_format='  |{bar:15}| {n_fmt}/{total_fmt} Uploaded'):\n",
    "      shutil.move(filename, INSTANCE_DIR)\n",
    "      extension = filename.split(\".\")[-1]\n",
    "      identifier=filename.split(\".\")[0]\n",
    "      new_path_with_file = os.path.join(INSTANCE_DIR, filename)\n",
    "      file = Image.open(new_path_with_file)\n",
    "      width, height = file.size\n",
    "      if file.size !=(Crop_size, Crop_size):\n",
    "        image=crop_image(file, Crop_size)\n",
    "        if extension.upper()==\"JPG\" or extension.upper()==\"jpg\":\n",
    "            image[0] = image[0].convert(\"RGB\")\n",
    "            image[0].save(new_path_with_file, format=\"JPEG\", quality = 100)\n",
    "        else:\n",
    "            image[0].save(new_path_with_file, format=extension.upper())\n",
    "      clear_output()\n",
    "  else:\n",
    "    for filename in tqdm(uploaded.keys(), bar_format='  |{bar:15}| {n_fmt}/{total_fmt} Uploaded'):\n",
    "      shutil.move(filename, INSTANCE_DIR)\n",
    "      clear_output()\n",
    "  print('\\n\u001b[1;32mDone, proceed to the next cell')\n",
    "\n",
    "with capture.capture_output() as cap:\n",
    "  %cd \"$INSTANCE_DIR\"\n",
    "  !find . -name \"* *\" -type f | rename 's/ /-/g'\n",
    "  %cd \"$CAPTIONS_DIR\"\n",
    "  !find . -name \"* *\" -type f | rename 's/ /-/g'\n",
    "  \n",
    "  %cd $SESSION_DIR\n",
    "  !rm instance_images.zip captions.zip\n",
    "  !zip -r instance_images instance_images\n",
    "  !zip -r captions captions\n",
    "  %cd /content"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "Baw78R-w4T2j"
   },
   "outputs": [],
   "source": [
    "import ipywidgets as widgets\n",
    "from io import BytesIO\n",
    "#@markdown #Captions (optional)\n",
    "\n",
    "#@markdown - Open a tool to manually `create` captions or edit existing captions of the instance images, do not use captions when training on a face.\n",
    "\n",
    "paths=\"\"\n",
    "out=\"\"\n",
    "widgets_l=\"\"\n",
    "clear_output()\n",
    "def Caption(path):\n",
    "    if path!=\"Select an instance image to caption\":\n",
    "      \n",
    "      name = os.path.splitext(os.path.basename(path))[0]\n",
    "      ext=os.path.splitext(os.path.basename(path))[-1][1:]\n",
    "      if ext==\"jpg\" or \"JPG\":\n",
    "        ext=\"JPEG\"      \n",
    "\n",
    "      if os.path.exists(CAPTIONS_DIR+\"/\"+name + '.txt'):\n",
    "        with open(CAPTIONS_DIR+\"/\"+name + '.txt', 'r') as f:\n",
    "            text = f.read()\n",
    "      else:\n",
    "        with open(CAPTIONS_DIR+\"/\"+name + '.txt', 'w') as f:\n",
    "            f.write(\"\")\n",
    "            with open(CAPTIONS_DIR+\"/\"+name + '.txt', 'r') as f:\n",
    "                text = f.read()   \n",
    "\n",
    "      img=Image.open(os.path.join(INSTANCE_DIR,path))\n",
    "      img=img.convert(\"RGB\")\n",
    "      img=img.resize((420, 420))\n",
    "      image_bytes = BytesIO()\n",
    "      img.save(image_bytes, format=ext, qualiy=10)\n",
    "      image_bytes.seek(0)\n",
    "      image_data = image_bytes.read()\n",
    "      img= image_data  \n",
    "      image = widgets.Image(\n",
    "          value=img,\n",
    "          width=420,\n",
    "          height=420\n",
    "      )\n",
    "      text_area = widgets.Textarea(value=text, description='', disabled=False, layout={'width': '300px', 'height': '120px'})\n",
    "      \n",
    "\n",
    "      def update_text(text):\n",
    "          with open(CAPTIONS_DIR+\"/\"+name + '.txt', 'w') as f:\n",
    "              f.write(text)\n",
    "\n",
    "      button = widgets.Button(description='Save', button_style='success')\n",
    "      button.on_click(lambda b: update_text(text_area.value))\n",
    "\n",
    "      return widgets.VBox([widgets.HBox([image, text_area, button])])\n",
    "\n",
    "\n",
    "paths = os.listdir(INSTANCE_DIR)\n",
    "widgets_l = widgets.Select(options=[\"Select an instance image to caption\"]+paths, rows=25)\n",
    "\n",
    "\n",
    "out = widgets.Output()\n",
    "\n",
    "def click(change):\n",
    "    with out:\n",
    "        out.clear_output()\n",
    "        display(Caption(change.new))\n",
    "\n",
    "widgets_l.observe(click, names='value')\n",
    "display(widgets.HBox([widgets_l, out]))"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {
    "id": "ZnmQYfZilzY6"
   },
   "source": [
    "# Training"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "1-9QbkfAVYYU"
   },
   "outputs": [],
   "source": [
    "#@markdown ---\n",
    "#@markdown #Start DreamBooth\n",
    "#@markdown ---\n",
    "import os\n",
    "from IPython.display import clear_output\n",
    "from google.colab import runtime\n",
    "from subprocess import getoutput\n",
    "import time\n",
    "import random\n",
    "\n",
    "if os.path.exists(INSTANCE_DIR+\"/.ipynb_checkpoints\"):\n",
    "  %rm -r $INSTANCE_DIR\"/.ipynb_checkpoints\"\n",
    "\n",
    "if os.path.exists(CAPTIONS_DIR+\"/.ipynb_checkpoints\"):\n",
    "  %rm -r $CAPTIONS_DIR\"/.ipynb_checkpoints\"\n",
    "\n",
    "Resume_Training = False #@param {type:\"boolean\"}\n",
    "\n",
    "if resume and not Resume_Training:\n",
    "  print('\u001b[1;31mOverwrite your previously trained model ? answering \"yes\" will train a new model, answering \"no\" will resume the training of the previous model?  yes or no ?\u001b[0m')\n",
    "  while True:\n",
    "    ansres=input('')\n",
    "    if ansres=='no':\n",
    "      Resume_Training = True\n",
    "      break\n",
    "    elif ansres=='yes':\n",
    "      Resume_Training = False\n",
    "      resume= False\n",
    "      break\n",
    "\n",
    "while not Resume_Training and MODEL_NAME==\"\":\n",
    "  print('\u001b[1;31mNo model found, use the \"Model Download\" cell to download a model.')\n",
    "  time.sleep(5)\n",
    "\n",
    "#@markdown  - If you're not satisfied with the result, check this box, run again the cell and it will continue training the current model.\n",
    "\n",
    "MODELT_NAME=MODEL_NAME\n",
    "\n",
    "UNet_Training_Steps=1500 #@param{type: 'number'}\n",
    "UNet_Learning_Rate = 2e-6 #@param [\"2e-5\",\"1e-5\",\"9e-6\",\"8e-6\",\"7e-6\",\"6e-6\",\"5e-6\", \"4e-6\", \"3e-6\", \"2e-6\"] {type:\"raw\"}\n",
    "untlr=UNet_Learning_Rate\n",
    "\n",
    "#@markdown - These default settings are for a dataset of 10 pictures which is enough for training a face, start with 1500 or lower, test the model, if not enough, resume training for 200 steps, keep testing until you get the desired output, `set it to 0 to train only the text_encoder`.\n",
    "\n",
    "Text_Encoder_Training_Steps=350 #@param{type: 'number'}\n",
    "\n",
    "#@markdown - 200-450 steps is enough for a small dataset, keep this number small to avoid overfitting, set to 0 to disable, `set it to 0 before resuming training if it is already trained`.\n",
    "\n",
    "Text_Encoder_Learning_Rate = 1e-6 #@param [\"2e-6\", \"1e-6\",\"8e-7\",\"6e-7\",\"5e-7\",\"4e-7\"] {type:\"raw\"}\n",
    "txlr=Text_Encoder_Learning_Rate\n",
    "\n",
    "#@markdown - Learning rate for the text_encoder, keep it low to avoid overfitting (1e-6 is higher than 4e-7)\n",
    "\n",
    "\n",
    "trnonltxt=\"\"\n",
    "if UNet_Training_Steps==0:\n",
    "   trnonltxt=\"--train_only_text_encoder\"\n",
    "\n",
    "Seed=''\n",
    "\n",
    "ofstnse=\"\"\n",
    "Offset_Noise = False #@param {type:\"boolean\"}\n",
    "#@markdown - Always use it for style training.\n",
    "\n",
    "if Offset_Noise:\n",
    "  ofstnse=\"--offset_noise\"\n",
    "\n",
    "External_Captions = False #@param {type:\"boolean\"}\n",
    "#@markdown - Get the captions from a text file for each instance image.\n",
    "extrnlcptn=\"\"\n",
    "if External_Captions:\n",
    "  extrnlcptn=\"--external_captions\"\n",
    "\n",
    "Resolution = \"512\" #@param [\"512\", \"576\", \"640\", \"704\", \"768\", \"832\", \"896\", \"960\", \"1024\"]\n",
    "Res=int(Resolution)\n",
    "\n",
    "#@markdown - Higher resolution = Higher quality, make sure the instance images are cropped to this selected size (or larger).\n",
    "\n",
    "fp16 = True\n",
    "\n",
    "if Seed =='' or Seed=='0':\n",
    "  Seed=random.randint(1, 999999)\n",
    "else:\n",
    "  Seed=int(Seed)\n",
    "\n",
    "if fp16:\n",
    "  prec=\"fp16\"\n",
    "else:\n",
    "  prec=\"no\"\n",
    "\n",
    "precision=prec\n",
    "\n",
    "resuming=\"\"\n",
    "if Resume_Training and os.path.exists(OUTPUT_DIR+'/unet/diffusion_pytorch_model.bin'):\n",
    "  MODELT_NAME=OUTPUT_DIR\n",
    "  print('\u001b[1;32mResuming Training...\u001b[0m')\n",
    "  resuming=\"Yes\"\n",
    "elif Resume_Training and not os.path.exists(OUTPUT_DIR+'/unet/diffusion_pytorch_model.bin'):\n",
    "  print('\u001b[1;31mPrevious model not found, training a new model...\u001b[0m')\n",
    "  MODELT_NAME=MODEL_NAME\n",
    "  while MODEL_NAME==\"\":\n",
    "    print('\u001b[1;31mNo model found, use the \"Model Download\" cell to download a model.')\n",
    "    time.sleep(5)\n",
    "\n",
    "V2=False\n",
    "if os.path.getsize(MODELT_NAME+\"/text_encoder/pytorch_model.bin\") > 670901463:\n",
    "  V2=True\n",
    "\n",
    "s = getoutput('nvidia-smi')\n",
    "GCUNET=\"--gradient_checkpointing\"\n",
    "TexRes=Res\n",
    "if Res<=768:\n",
    "  GCUNET=\"\"\n",
    "\n",
    "if V2:  \n",
    "  if Res>704:\n",
    "    GCUNET=\"--gradient_checkpointing\"\n",
    "  if Res>576:\n",
    "    TexRes=576\n",
    "\n",
    "if 'A100' in s :\n",
    "   GCUNET=\"\"\n",
    "   TexRes=Res\n",
    "\n",
    "\n",
    "Enable_text_encoder_training= True\n",
    "\n",
    "if Text_Encoder_Training_Steps==0 :\n",
    "   Enable_text_encoder_training= False\n",
    "else:\n",
    "  stptxt=Text_Encoder_Training_Steps\n",
    "\n",
    "\n",
    "#@markdown ---------------------------\n",
    "Save_Checkpoint_Every_n_Steps = False #@param {type:\"boolean\"}\n",
    "Save_Checkpoint_Every=500 #@param{type: 'number'}\n",
    "if Save_Checkpoint_Every==None:\n",
    "  Save_Checkpoint_Every=1\n",
    "#@markdown - Minimum 200 steps between each save.\n",
    "stp=0\n",
    "Start_saving_from_the_step=500 #@param{type: 'number'}\n",
    "if Start_saving_from_the_step==None:\n",
    "  Start_saving_from_the_step=0\n",
    "if (Start_saving_from_the_step < 200):\n",
    "  Start_saving_from_the_step=Save_Checkpoint_Every\n",
    "stpsv=Start_saving_from_the_step\n",
    "if Save_Checkpoint_Every_n_Steps:\n",
    "  stp=Save_Checkpoint_Every\n",
    "#@markdown - Start saving intermediary checkpoints from this step.\n",
    "\n",
    "Disconnect_after_training=False #@param {type:\"boolean\"}\n",
    "\n",
    "#@markdown - Auto-disconnect from google colab after the training to avoid wasting compute units.\n",
    "\n",
    "def dump_only_textenc(trnonltxt, MODELT_NAME, INSTANCE_DIR, OUTPUT_DIR, PT, Seed, precision, Training_Steps):\n",
    "    \n",
    "    !accelerate launch /content/diffusers/examples/dreambooth/train_dreambooth.py \\\n",
    "    $trnonltxt \\\n",
    "    $extrnlcptn \\\n",
    "    $ofstnse \\\n",
    "    --image_captions_filename \\\n",
    "    --train_text_encoder \\\n",
    "    --dump_only_text_encoder \\\n",
    "    --pretrained_model_name_or_path=\"$MODELT_NAME\" \\\n",
    "    --instance_data_dir=\"$INSTANCE_DIR\" \\\n",
    "    --output_dir=\"$OUTPUT_DIR\" \\\n",
    "    --captions_dir=\"$CAPTIONS_DIR\" \\\n",
    "    --instance_prompt=\"$PT\" \\\n",
    "    --seed=$Seed \\\n",
    "    --resolution=$TexRes \\\n",
    "    --mixed_precision=$precision \\\n",
    "    --train_batch_size=1 \\\n",
    "    --gradient_accumulation_steps=1 --gradient_checkpointing \\\n",
    "    --use_8bit_adam \\\n",
    "    --learning_rate=$txlr \\\n",
    "    --lr_scheduler=\"linear\" \\\n",
    "    --lr_warmup_steps=0 \\\n",
    "    --max_train_steps=$Training_Steps\n",
    "\n",
    "def train_only_unet(stpsv, stp, SESSION_DIR, MODELT_NAME, INSTANCE_DIR, OUTPUT_DIR, PT, Seed, Res, precision, Training_Steps):\n",
    "    clear_output()\n",
    "    if resuming==\"Yes\":\n",
    "      print('\u001b[1;32mResuming Training...\u001b[0m')\n",
    "    print('\u001b[1;33mTraining the UNet...\u001b[0m')\n",
    "    !accelerate launch /content/diffusers/examples/dreambooth/train_dreambooth.py \\\n",
    "    $extrnlcptn \\\n",
    "    $ofstnse \\\n",
    "    --image_captions_filename \\\n",
    "    --train_only_unet \\\n",
    "    --save_starting_step=$stpsv \\\n",
    "    --save_n_steps=$stp \\\n",
    "    --Session_dir=$SESSION_DIR \\\n",
    "    --pretrained_model_name_or_path=\"$MODELT_NAME\" \\\n",
    "    --instance_data_dir=\"$INSTANCE_DIR\" \\\n",
    "    --output_dir=\"$OUTPUT_DIR\" \\\n",
    "    --captions_dir=\"$CAPTIONS_DIR\" \\\n",
    "    --instance_prompt=\"$PT\" \\\n",
    "    --seed=$Seed \\\n",
    "    --resolution=$Res \\\n",
    "    --mixed_precision=$precision \\\n",
    "    --train_batch_size=1 \\\n",
    "    --gradient_accumulation_steps=1 $GCUNET \\\n",
    "    --use_8bit_adam \\\n",
    "    --learning_rate=$untlr \\\n",
    "    --lr_scheduler=\"linear\" \\\n",
    "    --lr_warmup_steps=0 \\\n",
    "    --max_train_steps=$Training_Steps\n",
    "\n",
    "\n",
    "if Enable_text_encoder_training :\n",
    "  print('\u001b[1;33mTraining the text encoder...\u001b[0m')\n",
    "  if os.path.exists(OUTPUT_DIR+'/'+'text_encoder_trained'):\n",
    "    %rm -r $OUTPUT_DIR\"/text_encoder_trained\"\n",
    "  dump_only_textenc(trnonltxt, MODELT_NAME, INSTANCE_DIR, OUTPUT_DIR, PT, Seed, precision, Training_Steps=stptxt)\n",
    "\n",
    "\n",
    "if UNet_Training_Steps!=0:\n",
    "  train_only_unet(stpsv, stp, SESSION_DIR, MODELT_NAME, INSTANCE_DIR, OUTPUT_DIR, PT, Seed, Res, precision, Training_Steps=UNet_Training_Steps)\n",
    "\n",
    "if UNet_Training_Steps==0 and Text_Encoder_Training_Steps==0 :\n",
    "  print('\u001b[1;32mNothing to do')\n",
    "else:\n",
    "  if os.path.exists('/content/models/'+INSTANCE_NAME+'/unet/diffusion_pytorch_model.bin'):\n",
    "    prc=\"--fp16\" if precision==\"fp16\" else \"\"\n",
    "    !python /content/diffusers/scripts/convertosdv2.py $prc $OUTPUT_DIR $SESSION_DIR/$Session_Name\".ckpt\"\n",
    "    clear_output()\n",
    "    if os.path.exists(SESSION_DIR+\"/\"+INSTANCE_NAME+'.ckpt'):\n",
    "      clear_output()\n",
    "      print(\"\u001b[1;32mDONE, the CKPT model is in your Gdrive in the sessions folder\")\n",
    "      if Disconnect_after_training :\n",
    "        time.sleep(20)\n",
    "        runtime.unassign()\n",
    "    else:\n",
    "      print(\"\u001b[1;31mSomething went wrong\")\n",
    "  else:\n",
    "    print(\"\u001b[1;31mSomething went wrong\")"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {
    "id": "ehi1KKs-l-ZS"
   },
   "source": [
    "# Test The Trained Model"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "iAZGngFcI8hq"
   },
   "outputs": [],
   "source": [
    "import os\n",
    "import time\n",
    "import sys\n",
    "import fileinput\n",
    "from IPython.display import clear_output\n",
    "from subprocess import getoutput\n",
    "from IPython.utils import capture\n",
    "from pyngrok import ngrok, conf\n",
    "import base64\n",
    "\n",
    "blasphemy=base64.b64decode((\"d2VidWk=\")).decode('ascii')\n",
    "\n",
    "Previous_Session=\"\" #@param{type: 'string'}\n",
    "\n",
    "#@markdown - Leave empty if you want to use the current trained model.\n",
    "\n",
    "Use_Custom_Path = False #@param {type:\"boolean\"}\n",
    "\n",
    "try:\n",
    "  INSTANCE_NAME\n",
    "  INSTANCET=INSTANCE_NAME\n",
    "except:\n",
    "  pass\n",
    "#@markdown - if checked, an input box will ask the full path to a desired model.\n",
    "\n",
    "if Previous_Session!=\"\":\n",
    "  INSTANCET=Previous_Session\n",
    "  INSTANCET=INSTANCET.replace(\" \",\"_\")\n",
    "\n",
    "if Use_Custom_Path:\n",
    "  try:\n",
    "    INSTANCET\n",
    "    del INSTANCET\n",
    "  except:\n",
    "    pass\n",
    "\n",
    "try:\n",
    "  INSTANCET\n",
    "  if Previous_Session!=\"\":\n",
    "    path_to_trained_model='/content/gdrive/MyDrive/Fast-Dreambooth/Sessions/'+Previous_Session+\"/\"+Previous_Session+'.ckpt'\n",
    "  else:\n",
    "    path_to_trained_model=SESSION_DIR+\"/\"+INSTANCET+'.ckpt'\n",
    "except:\n",
    "  print('\u001b[1;31mIt seems that you did not perform training during this session \u001b[1;32mor you chose to use a custom path,\\nprovide the full path to the model (including the name of the model):\\n')\n",
    "  path_to_trained_model=input()\n",
    "     \n",
    "while not os.path.exists(path_to_trained_model):\n",
    "   print(\"\u001b[1;31mThe model doesn't exist on you Gdrive, use the file explorer to get the path : \")\n",
    "   path_to_trained_model=input()\n",
    "   \n",
    "fgitclone = \"git clone --depth 1\"\n",
    "\n",
    "with capture.capture_output() as cap:\n",
    "    if not os.path.exists('/content/gdrive/MyDrive'):\n",
    "      !mkdir -p /content/gdrive/MyDrive\n",
    "\n",
    "if not os.path.exists('/content/gdrive/MyDrive/sd/stablediffusion'):\n",
    "    !wget -q -O /content/sd_rep.tar.zst https://huggingface.co/TheLastBen/dependencies/resolve/main/sd_rep.tar.zst\n",
    "    !tar -C  /content/gdrive/MyDrive --zstd -xf /content/sd_rep.tar.zst\n",
    "    !rm /content/sd_rep.tar.zst\n",
    "    clear_output()\n",
    "\n",
    "with capture.capture_output() as cap:\n",
    "  %cd /content/gdrive/MyDrive/sd\n",
    "  !git clone -q --branch master https://github.com/AUTOMATIC1111/stable-diffusion-$blasphemy\n",
    "  %cd stable-diffusion-$blasphemy\n",
    "  !mkdir cache\n",
    "  !sed -i 's@~/.cache@/content/gdrive/MyDrive/sd/stable-diffusion-{blasphemy}/cache@' /usr/local/lib/python3.10/dist-packages/transformers/utils/hub.py\n",
    "\n",
    "  clear_output()\n",
    "  !git reset --hard\n",
    "  time.sleep(1)\n",
    "  !rm webui.sh\n",
    "  !git pull\n",
    "  !git fetch --unshallow\n",
    "  !git checkout a9eab236d7e8afa4d6205127904a385b2c43bb24\n",
    "  \n",
    "with capture.capture_output() as cap:\n",
    "  if not os.path.exists('/tools/node/bin/lt'):\n",
    "    !npm install -g localtunnel\n",
    "\n",
    "Ngrok_token = \"\" #@param {type:\"string\"}\n",
    "\n",
    "#@markdown - Input your ngrok token if you want to use ngrok server.\n",
    "\n",
    "Use_localtunnel = False #@param {type:\"boolean\"}\n",
    "\n",
    "User = \"\" #@param {type:\"string\"}\n",
    "Password= \"\" #@param {type:\"string\"}\n",
    "#@markdown - Add credentials to your Gradio interface (optional).\n",
    "\n",
    "auth=f\"--gradio-auth {User}:{Password}\"\n",
    "if User ==\"\" or Password==\"\":\n",
    "  auth=\"\"\n",
    "\n",
    "with capture.capture_output() as cap:\n",
    "  %cd modules\n",
    "  !wget -q -O paths.py https://github.com/TheLastBen/fast-stable-diffusion/raw/5632d2ef7fffd940976538d270854ec4faf26855/AUTOMATIC1111_files/paths.py\n",
    "  !wget -q -O extras.py https://github.com/AUTOMATIC1111/stable-diffusion-$blasphemy/raw/a9eab236d7e8afa4d6205127904a385b2c43bb24/modules/extras.py\n",
    "  !wget -q -O sd_models.py https://github.com/AUTOMATIC1111/stable-diffusion-$blasphemy/raw/a9eab236d7e8afa4d6205127904a385b2c43bb24/modules/sd_models.py\n",
    "  !wget -q -O /usr/local/lib/python3.10/dist-packages/gradio/blocks.py https://github.com/TheLastBen/fast-stable-diffusion/raw/7ff88eaa1fb4997bacd9845bd487f9a14335d625/AUTOMATIC1111_files/blocks.py\n",
    "  %cd /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy/\n",
    "\n",
    "  !sed -i \"s@os.path.splitext(checkpoint_file)@os.path.splitext(checkpoint_file); map_location='cuda'@\" /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy/modules/sd_models.py\n",
    "  !sed -i 's@ui.create_ui().*@ui.create_ui();shared.demo.queue(concurrency_count=999999,status_update_rate=0.1)@' /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy/webui.py\n",
    "  !sed -i \"s@map_location='cpu'@map_location='cuda'@\" /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy/modules/extras.py\n",
    "  !sed -i 's@print(\\\"No module.*@@' /content/gdrive/MyDrive/sd/stablediffusion/ldm/modules/diffusionmodules/model.py\n",
    "  !sed -i 's@\\\"quicksettings\\\": OptionInfo(.*@\"quicksettings\": OptionInfo(\"sd_model_checkpoint,  sd_vae, CLIP_stop_at_last_layers, inpainting_mask_weight, initial_noise_multiplier\", \"Quicksettings list\"),@' /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy/modules/shared.py\n",
    "\n",
    "share=''\n",
    "if Ngrok_token!=\"\":\n",
    "  ngrok.kill()\n",
    "  srv=ngrok.connect(7860, pyngrok_config=conf.PyngrokConfig(auth_token=Ngrok_token) , bind_tls=True).public_url\n",
    "\n",
    "  for line in fileinput.input('/usr/local/lib/python3.10/dist-packages/gradio/blocks.py', inplace=True):\n",
    "    if line.strip().startswith('self.server_name ='):\n",
    "        line = f'            self.server_name = \"{srv[8:]}\"\\n'\n",
    "    if line.strip().startswith('self.protocol = \"https\"'):\n",
    "        line = '            self.protocol = \"https\"\\n'\n",
    "    if line.strip().startswith('if self.local_url.startswith(\"https\") or self.is_colab'):\n",
    "        line = ''\n",
    "    if line.strip().startswith('else \"http\"'):\n",
    "        line = ''\n",
    "    sys.stdout.write(line)\n",
    "\n",
    "elif Use_localtunnel:\n",
    "  with capture.capture_output() as cap:\n",
    "    share=''\n",
    "    %cd /content\n",
    "    !nohup lt --port 7860 > srv.txt 2>&1 &\n",
    "    time.sleep(2)\n",
    "    !grep -o 'https[^ ]*' /content/srv.txt >srvr.txt\n",
    "    time.sleep(2)\n",
    "    srv= getoutput('cat /content/srvr.txt')\n",
    "\n",
    "    for line in fileinput.input('/usr/local/lib/python3.10/dist-packages/gradio/blocks.py', inplace=True):\n",
    "      if line.strip().startswith('self.server_name ='):\n",
    "          line = f'            self.server_name = \"{srv[8:]}\"\\n'\n",
    "      if line.strip().startswith('self.protocol = \"https\"'):\n",
    "          line = '            self.protocol = \"https\"\\n'\n",
    "      if line.strip().startswith('if self.local_url.startswith(\"https\") or self.is_colab'):\n",
    "          line = ''\n",
    "      if line.strip().startswith('else \"http\"'):\n",
    "          line = ''\n",
    "      sys.stdout.write(line)\n",
    "            \n",
    "    !rm /content/srv.txt /content/srvr.txt\n",
    "    %cd /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy\n",
    "\n",
    "else:\n",
    "  share='--share'\n",
    "\n",
    "configf=\"--api --disable-safe-unpickle --enable-insecure-extension-access --no-half-vae --opt-sdp-attention --no-download-sd-model --disable-console-progressbars\"\n",
    "\n",
    "clear_output()\n",
    "\n",
    "if os.path.isfile(path_to_trained_model):\n",
    "  !python /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy/webui.py $share --ckpt \"$path_to_trained_model\" $auth $configf\n",
    "else:\n",
    "  !python /content/gdrive/MyDrive/sd/stable-diffusion-$blasphemy/webui.py $share --ckpt-dir \"$path_to_trained_model\" $auth $configf"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {
    "id": "d_mQ23XsOc5R"
   },
   "source": [
    "# Upload The Trained Model to Hugging Face "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "NTqUIuhROdH4"
   },
   "outputs": [],
   "source": [
    "from slugify import slugify\n",
    "from huggingface_hub import HfApi, HfFolder, CommitOperationAdd\n",
    "from huggingface_hub import create_repo\n",
    "from IPython.display import display_markdown\n",
    "from IPython.display import clear_output\n",
    "from IPython.utils import capture\n",
    "from google.colab import files\n",
    "import shutil\n",
    "import time\n",
    "import os\n",
    "\n",
    "Upload_sample_images = False #@param {type:\"boolean\"}\n",
    "#@markdown - Upload showcase images of your trained model\n",
    "\n",
    "Name_of_your_concept = \"\" #@param {type:\"string\"}\n",
    "if(Name_of_your_concept == \"\"):\n",
    "  Name_of_your_concept = Session_Name\n",
    "Name_of_your_concept=Name_of_your_concept.replace(\" \",\"-\")  \n",
    "  \n",
    "#@markdown - [Create a write access token](https://huggingface.co/settings/tokens) , go to \"New token\" -> Role : Write. A regular read token won't work here.\n",
    "hf_token_write = \"\" #@param {type:\"string\"}\n",
    "if hf_token_write ==\"\":\n",
    "  print('\u001b[1;32mYour Hugging Face write access token : ')\n",
    "  hf_token_write=input()\n",
    "\n",
    "hf_token = hf_token_write\n",
    "\n",
    "api = HfApi()\n",
    "your_username = api.whoami(token=hf_token)[\"name\"]\n",
    "\n",
    "repo_id = f\"{your_username}/{slugify(Name_of_your_concept)}\"\n",
    "output_dir = f'/content/models/'+INSTANCE_NAME\n",
    "\n",
    "def bar(prg):\n",
    "    br=\"\u001b[1;33mUploading to HuggingFace : \" '\u001b[0m|'+'█' * prg + ' ' * (25-prg)+'| ' +str(prg*4)+ \"%\"\n",
    "    return br\n",
    "\n",
    "print(\"\u001b[1;32mLoading...\")\n",
    "\n",
    "NM=\"False\"\n",
    "if os.path.getsize(OUTPUT_DIR+\"/text_encoder/pytorch_model.bin\") > 670901463:\n",
    "  NM=\"True\"\n",
    "\n",
    "with capture.capture_output() as cap:\n",
    "  if NM==\"False\":\n",
    "    %cd $OUTPUT_DIR\n",
    "    !rm -r safety_checker feature_extractor .git\n",
    "    !rm model_index.json\n",
    "    !git init\n",
    "    !git lfs install --system --skip-repo\n",
    "    !git remote add -f origin  \"https://USER:{hf_token}@huggingface.co/runwayml/stable-diffusion-v1-5\"\n",
    "    !git config core.sparsecheckout true\n",
    "    !echo -e \"feature_extractor\\nsafety_checker\\nmodel_index.json\" > .git/info/sparse-checkout\n",
    "    !git pull origin main\n",
    "    !rm -r .git\n",
    "    %cd /content\n",
    "  else:\n",
    "    %cd $OUTPUT_DIR\n",
    "    !rm -r feature_extractor .git\n",
    "    !git init\n",
    "    !git lfs install --system --skip-repo\n",
    "    !git remote add -f origin  \"https://USER:{hf_token}@huggingface.co/stabilityai/stable-diffusion-2-1\"\n",
    "    !git config core.sparsecheckout true\n",
    "    !echo -e \"feature_extractor\" > .git/info/sparse-checkout\n",
    "    !git pull origin main\n",
    "    !rm -r .git\n",
    "    %cd /content\n",
    "\n",
    "\n",
    "image_string = \"\"\n",
    "\n",
    "if os.path.exists('/content/sample_images'):\n",
    "  !rm -r /content/sample_images\n",
    "Samples=\"/content/sample_images\"\n",
    "!mkdir $Samples\n",
    "clear_output()\n",
    "\n",
    "if Upload_sample_images:\n",
    "\n",
    "  print(\"\u001b[1;32mUpload Sample images of the model\")\n",
    "  uploaded = files.upload()\n",
    "  for filename in uploaded.keys():\n",
    "    shutil.move(filename, Samples)\n",
    "  %cd $Samples\n",
    "  !find . -name \"* *\" -type f | rename 's/ /_/g'\n",
    "  %cd /content\n",
    "  clear_output()\n",
    "\n",
    "  print(bar(1))\n",
    "\n",
    "  images_upload = os.listdir(Samples)\n",
    "  instance_prompt_list = []\n",
    "  for i, image in enumerate(images_upload):\n",
    "      image_string = f'''\n",
    "  {image_string}![{i}](https://huggingface.co/{repo_id}/resolve/main/sample_images/{image})\n",
    "      '''\n",
    "    \n",
    "readme_text = f'''---\n",
    "license: creativeml-openrail-m\n",
    "tags:\n",
    "- text-to-image\n",
    "- stable-diffusion\n",
    "---\n",
    "### {Name_of_your_concept} Dreambooth model trained by {api.whoami(token=hf_token)[\"name\"]} with [TheLastBen's fast-DreamBooth](https://colab.research.google.com/github/TheLastBen/fast-stable-diffusion/blob/main/fast-DreamBooth.ipynb) notebook\n",
    "\n",
    "\n",
    "Test the concept via A1111 Colab [fast-Colab-A1111](https://colab.research.google.com/github/TheLastBen/fast-stable-diffusion/blob/main/fast_stable_diffusion_AUTOMATIC1111.ipynb)\n",
    "\n",
    "Sample pictures of this concept:\n",
    "{image_string}\n",
    "'''\n",
    "#Save the readme to a file\n",
    "readme_file = open(\"README.md\", \"w\")\n",
    "readme_file.write(readme_text)\n",
    "readme_file.close()\n",
    "\n",
    "operations = [\n",
    "  CommitOperationAdd(path_in_repo=\"README.md\", path_or_fileobj=\"README.md\"),\n",
    "  CommitOperationAdd(path_in_repo=f\"{Session_Name}.ckpt\",path_or_fileobj=MDLPTH)\n",
    "\n",
    "]\n",
    "create_repo(repo_id,private=True, token=hf_token)\n",
    "\n",
    "api.create_commit(\n",
    "  repo_id=repo_id,\n",
    "  operations=operations,\n",
    "  commit_message=f\"Upload the concept {Name_of_your_concept} embeds and token\",\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "api.upload_folder(\n",
    "  folder_path=OUTPUT_DIR+\"/feature_extractor\",\n",
    "  path_in_repo=\"feature_extractor\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(4))\n",
    "\n",
    "if NM==\"False\":\n",
    "  api.upload_folder(\n",
    "    folder_path=OUTPUT_DIR+\"/safety_checker\",\n",
    "    path_in_repo=\"safety_checker\",\n",
    "    repo_id=repo_id,\n",
    "    token=hf_token\n",
    "  )\n",
    "\n",
    "clear_output()\n",
    "print(bar(8))\n",
    "\n",
    "\n",
    "api.upload_folder(\n",
    "  folder_path=OUTPUT_DIR+\"/scheduler\",\n",
    "  path_in_repo=\"scheduler\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(9))\n",
    "\n",
    "api.upload_folder(\n",
    "  folder_path=OUTPUT_DIR+\"/text_encoder\",\n",
    "  path_in_repo=\"text_encoder\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(12))\n",
    "\n",
    "api.upload_folder(\n",
    "  folder_path=OUTPUT_DIR+\"/tokenizer\",\n",
    "  path_in_repo=\"tokenizer\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(13))\n",
    "\n",
    "api.upload_folder(\n",
    "  folder_path=OUTPUT_DIR+\"/unet\",\n",
    "  path_in_repo=\"unet\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(21))\n",
    "\n",
    "api.upload_folder(\n",
    "  folder_path=OUTPUT_DIR+\"/vae\",\n",
    "  path_in_repo=\"vae\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(23))\n",
    "\n",
    "api.upload_file(\n",
    "  path_or_fileobj=OUTPUT_DIR+\"/model_index.json\",\n",
    "  path_in_repo=\"model_index.json\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(24))\n",
    "\n",
    "api.upload_folder(\n",
    "  folder_path=Samples,\n",
    "  path_in_repo=\"sample_images\",\n",
    "  repo_id=repo_id,\n",
    "  token=hf_token\n",
    ")\n",
    "\n",
    "clear_output()\n",
    "print(bar(25))\n",
    "\n",
    "display_markdown(f'''## Your concept was saved successfully. [Click here to access it](https://huggingface.co/{repo_id})\n",
    "''', raw=True)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {
    "cellView": "form",
    "id": "iVqNi8IDzA1Z"
   },
   "outputs": [],
   "source": [
    "#@markdown #Free Gdrive Space\n",
    "\n",
    "#@markdown Display the list of sessions from your gdrive and choose which ones to remove.\n",
    "\n",
    "import ipywidgets as widgets\n",
    "\n",
    "Sessions=os.listdir(\"/content/gdrive/MyDrive/Fast-Dreambooth/Sessions\")\n",
    "\n",
    "s = widgets.Select(\n",
    "    options=Sessions,\n",
    "    rows=5,\n",
    "    description='',\n",
    "    disabled=False\n",
    ")\n",
    "\n",
    "out=widgets.Output()\n",
    "\n",
    "d = widgets.Button(\n",
    "    description='Remove',\n",
    "    disabled=False,\n",
    "    button_style='warning',\n",
    "    tooltip='Removet the selected session',\n",
    "    icon='warning'\n",
    ")\n",
    "\n",
    "def rem(d):\n",
    "    with out:\n",
    "        if s.value is not None:\n",
    "            clear_output()\n",
    "            print(\"\u001b[1;33mTHE SESSION \u001b[1;31m\"+s.value+\" \u001b[1;33mHAS BEEN REMOVED FROM YOUR GDRIVE\")\n",
    "            !rm -r '/content/gdrive/MyDrive/Fast-Dreambooth/Sessions/{s.value}'\n",
    "            s.options=os.listdir(\"/content/gdrive/MyDrive/Fast-Dreambooth/Sessions\")       \n",
    "        else:\n",
    "            d.close()\n",
    "            s.close()\n",
    "            clear_output()\n",
    "            print(\"\u001b[1;32mNOTHING TO REMOVE\")\n",
    "\n",
    "d.on_click(rem)\n",
    "if s.value is not None:\n",
    "    display(s,d,out)\n",
    "else:\n",
    "    print(\"\u001b[1;32mNOTHING TO REMOVE\")"
   ]
  }
 ],
 "metadata": {
  "accelerator": "GPU",
  "colab": {
   "collapsed_sections": [
    "bbKbx185zqlz",
    "AaLtXBbPleBr"
   ],
   "provenance": []
  },
  "kernelspec": {
   "display_name": "Python 3",
   "name": "python3"
  },
  "language_info": {
   "name": "python"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 0
}