GaumlessGraham commited on
Commit
6f2fa8b
·
verified ·
1 Parent(s): bed47e0

Create outRingAug.py

Browse files
Files changed (1) hide show
  1. outRingAug.py +352 -0
outRingAug.py ADDED
@@ -0,0 +1,352 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ # -*- coding: utf-8 -*-
2
+ """beths butterfly training.ipynb
3
+ Automatically generated by Colab.
4
+ Original file is located at
5
+ https://colab.research.google.com/drive/1SbxWXhffEnCJ6tVT6ZfTDbY2-cxb063U
6
+ # Train a diffusion model
7
+ Unconditional image generation is a popular application of diffusion models that generates images that look like those in the dataset used for training. Typically, the best results are obtained from finetuning a pretrained model on a specific dataset. You can find many of these checkpoints on the [Hub](https://huggingface.co/search/full-text?q=unconditional-image-generation&type=model), but if you can't find one you like, you can always train your own!
8
+ This tutorial will teach you how to train a [UNet2DModel](https://huggingface.co/docs/diffusers/main/en/api/models/unet2d#diffusers.UNet2DModel) from scratch on a subset of the [Smithsonian Butterflies](https://huggingface.co/datasets/huggan/smithsonian_butterflies_subset) dataset to generate your own 🦋 butterflies 🦋.
9
+ <Tip>
10
+ 💡 This training tutorial is based on the [Training with 🧨 Diffusers](https://colab.research.google.com/github/huggingface/notebooks/blob/main/diffusers/training_example.ipynb) notebook. For additional details and context about diffusion models like how they work, check out the notebook!
11
+ </Tip>
12
+ Before you begin, make sure you have 🤗 Datasets installed to load and preprocess image datasets, and 🤗 Accelerate, to simplify training on any number of GPUs. The following command will also install [TensorBoard](https://www.tensorflow.org/tensorboard) to visualize training metrics (you can also use [Weights & Biases](https://docs.wandb.ai/) to track your training).
13
+ """
14
+
15
+ # uncomment to install the necessary libraries in Colab
16
+ #!pip install diffusers[training]
17
+
18
+ """We encourage you to share your model with the community, and in order to do that, you'll need to login to your Hugging Face account (create one [here](https://hf.co/join) if you don't already have one!). You can login from a notebook and enter your token when prompted:"""
19
+
20
+ from huggingface_hub import notebook_login
21
+
22
+ notebook_login()
23
+
24
+ #!sudo apt -qq install git-lfs
25
+ #!git config --global credential.helper store
26
+
27
+ """Or login in from the terminal:
28
+ ```bash
29
+ huggingface-cli login
30
+ ```
31
+ Since the model checkpoints are quite large, install [Git-LFS](https://git-lfs.com/) to version these large files:
32
+ ```bash
33
+ !sudo apt -qq install git-lfs
34
+ !git config --global credential.helper store
35
+ ```
36
+ ## Training configuration
37
+ For convenience, create a `TrainingConfig` class containing the training hyperparameters (feel free to adjust them):
38
+ """
39
+
40
+ from dataclasses import dataclass
41
+
42
+
43
+ @dataclass
44
+ class TrainingConfig:
45
+ image_size = 256 # the generated image resolution
46
+ train_batch_size = 10
47
+ eval_batch_size = 16 # how many images to sample during evaluation
48
+ num_epochs = 2500
49
+ gradient_accumulation_steps = 1
50
+ learning_rate = 1e-4
51
+ lr_warmup_steps = 500
52
+ save_image_epochs = 50
53
+ save_model_epochs = 250
54
+ mixed_precision = "fp16" # `no` for float32, `fp16` for automatic mixed precision
55
+ output_dir = "7inchOuterRingAug" # the model name locally and on the HF Hub
56
+
57
+ push_to_hub = True # whether to upload the saved model to the HF Hub
58
+ hub_private_repo = False
59
+ overwrite_output_dir = False # KEEP THIS AS FALSE
60
+ seed = 0
61
+
62
+
63
+ config = TrainingConfig()
64
+
65
+ """## Load the dataset
66
+ You can easily load the [Smithsonian Butterflies](https://huggingface.co/datasets/huggan/smithsonian_butterflies_subset) dataset with the 🤗 Datasets library:
67
+ """
68
+
69
+ from datasets import load_dataset
70
+
71
+ config.dataset_name = "GaumlessGraham/0_007InchOuter1730_6_Aug"
72
+ dataset = load_dataset(config.dataset_name, split="train")
73
+
74
+ """<Tip>
75
+ 💡 You can find additional datasets from the [HugGan Community Event](https://huggingface.co/huggan) or you can use your own dataset by creating a local [`ImageFolder`](https://huggingface.co/docs/datasets/image_dataset#imagefolder). Set `config.dataset_name` to the repository id of the dataset if it is from the HugGan Community Event, or `imagefolder` if you're using your own images.
76
+ </Tip>
77
+ 🤗 Datasets uses the [Image](https://huggingface.co/docs/datasets/main/en/package_reference/main_classes#datasets.Image) feature to automatically decode the image data and load it as a [`PIL.Image`](https://pillow.readthedocs.io/en/stable/reference/Image.html) which we can visualize:
78
+ """
79
+
80
+ import matplotlib.pyplot as plt
81
+
82
+ fig, axs = plt.subplots(1, 4, figsize=(16, 4))
83
+ for i, image in enumerate(dataset[:4]["image"]):
84
+ axs[i].imshow(image)
85
+ axs[i].set_axis_off()
86
+ fig.show()
87
+
88
+ """<div class="flex justify-center">
89
+ <img src="https://huggingface.co/datasets/huggingface/documentation-images/resolve/main/diffusers/butterflies_ds.png"/>
90
+ </div>
91
+ The images are all different sizes though, so you'll need to preprocess them first:
92
+ * `Resize` changes the image size to the one defined in `config.image_size`.
93
+ * `RandomHorizontalFlip` augments the dataset by randomly mirroring the images.
94
+ * `Normalize` is important to rescale the pixel values into a [-1, 1] range, which is what the model expects.
95
+ """
96
+
97
+ from torchvision import transforms
98
+
99
+ preprocess = transforms.Compose(
100
+ [
101
+ transforms.Resize((config.image_size, config.image_size)),
102
+
103
+ transforms.ToTensor(),
104
+ transforms.Normalize([0.5], [0.5]),
105
+ ]
106
+ )
107
+
108
+ """Use 🤗 Datasets' [set_transform](https://huggingface.co/docs/datasets/main/en/package_reference/main_classes#datasets.Dataset.set_transform) method to apply the `preprocess` function on the fly during training:"""
109
+
110
+ def transform(examples):
111
+ images = [preprocess(image.convert("RGB")) for image in examples["image"]]
112
+ return {"images": images}
113
+
114
+
115
+ dataset.set_transform(transform)
116
+
117
+ """Feel free to visualize the images again to confirm that they've been resized. Now you're ready to wrap the dataset in a [DataLoader](https://pytorch.org/docs/stable/data#torch.utils.data.DataLoader) for training!"""
118
+
119
+ import torch
120
+
121
+ train_dataloader = torch.utils.data.DataLoader(dataset, batch_size=config.train_batch_size, shuffle=True)
122
+
123
+ fig.show()
124
+
125
+ """## Create a UNet2DModel
126
+ Pretrained models in 🧨 Diffusers are easily created from their model class with the parameters you want. For example, to create a [UNet2DModel](https://huggingface.co/docs/diffusers/main/en/api/models/unet2d#diffusers.UNet2DModel):
127
+ """
128
+
129
+ from diffusers import UNet2DModel
130
+
131
+ model = UNet2DModel(
132
+ sample_size=config.image_size, # the target image resolution
133
+ in_channels=3, # the number of input channels, 3 for RGB images
134
+ out_channels=3, # the number of output channels
135
+ layers_per_block=2, # how many ResNet layers to use per UNet block
136
+ block_out_channels=(128, 128, 256, 256, 512, 512), # the number of output channels for each UNet block
137
+ down_block_types=(
138
+ "DownBlock2D", # a regular ResNet downsampling block
139
+ "DownBlock2D",
140
+ "DownBlock2D",
141
+ "DownBlock2D",
142
+ "AttnDownBlock2D", # a ResNet downsampling block with spatial self-attention
143
+ "DownBlock2D",
144
+ ),
145
+ up_block_types=(
146
+ "UpBlock2D", # a regular ResNet upsampling block
147
+ "AttnUpBlock2D", # a ResNet upsampling block with spatial self-attention
148
+ "UpBlock2D",
149
+ "UpBlock2D",
150
+ "UpBlock2D",
151
+ "UpBlock2D",
152
+ ),
153
+ )
154
+
155
+ """It is often a good idea to quickly check the sample image shape matches the model output shape:"""
156
+
157
+ sample_image = dataset[0]["images"].unsqueeze(0)
158
+ print("Input shape:", sample_image.shape)
159
+
160
+ print("Output shape:", model(sample_image, timestep=0).sample.shape)
161
+
162
+ """Great! Next, you'll need a scheduler to add some noise to the image.
163
+ ## Create a scheduler
164
+ The scheduler behaves differently depending on whether you're using the model for training or inference. During inference, the scheduler generates image from the noise. During training, the scheduler takes a model output - or a sample - from a specific point in the diffusion process and applies noise to the image according to a *noise schedule* and an *update rule*.
165
+ Let's take a look at the [DDPMScheduler](https://huggingface.co/docs/diffusers/main/en/api/schedulers/ddpm#diffusers.DDPMScheduler) and use the `add_noise` method to add some random noise to the `sample_image` from before:
166
+ """
167
+
168
+ import torch
169
+ from PIL import Image
170
+ from diffusers import DDPMScheduler
171
+
172
+ noise_scheduler = DDPMScheduler(num_train_timesteps=1000)
173
+ noise = torch.randn(sample_image.shape)
174
+ timesteps = torch.LongTensor([50])
175
+ noisy_image = noise_scheduler.add_noise(sample_image, noise, timesteps)
176
+
177
+ Image.fromarray(((noisy_image.permute(0, 2, 3, 1) + 1.0) * 127.5).type(torch.uint8).numpy()[0])
178
+
179
+ """<div class="flex justify-center">
180
+ <img src="https://huggingface.co/datasets/huggingface/documentation-images/resolve/main/diffusers/noisy_butterfly.png"/>
181
+ </div>
182
+ The training objective of the model is to predict the noise added to the image. The loss at this step can be calculated by:
183
+ """
184
+
185
+ import torch.nn.functional as F
186
+
187
+ noise_pred = model(noisy_image, timesteps).sample
188
+ loss = F.mse_loss(noise_pred, noise)
189
+
190
+ """## Train the model
191
+ By now, you have most of the pieces to start training the model and all that's left is putting everything together.
192
+ First, you'll need an optimizer and a learning rate scheduler:
193
+ """
194
+
195
+ from diffusers.optimization import get_cosine_schedule_with_warmup
196
+
197
+ optimizer = torch.optim.AdamW(model.parameters(), lr=config.learning_rate)
198
+ lr_scheduler = get_cosine_schedule_with_warmup(
199
+ optimizer=optimizer,
200
+ num_warmup_steps=config.lr_warmup_steps,
201
+ num_training_steps=(len(train_dataloader) * config.num_epochs),
202
+ )
203
+
204
+ """Then, you'll need a way to evaluate the model. For evaluation, you can use the [DDPMPipeline](https://huggingface.co/docs/diffusers/main/en/api/pipelines/ddpm#diffusers.DDPMPipeline) to generate a batch of sample images and save it as a grid:"""
205
+
206
+ from diffusers import DDPMPipeline
207
+ import math
208
+ import os
209
+
210
+
211
+ def make_grid(images, rows, cols):
212
+ w, h = images[0].size
213
+ grid = Image.new("RGB", size=(cols * w, rows * h))
214
+ for i, image in enumerate(images):
215
+ grid.paste(image, box=(i % cols * w, i // cols * h))
216
+ return grid
217
+
218
+
219
+ def evaluate(config, epoch, pipeline):
220
+ # Sample some images from random noise (this is the backward diffusion process).
221
+ # The default pipeline output type is `List[PIL.Image]`
222
+ images = pipeline(
223
+ batch_size=config.eval_batch_size,
224
+ generator=torch.manual_seed(config.seed),
225
+ ).images
226
+
227
+ # Make a grid out of the images
228
+ image_grid = make_grid(images, rows=4, cols=4)
229
+
230
+ # Save the images
231
+ test_dir = os.path.join(config.output_dir, "samples")
232
+ os.makedirs(test_dir, exist_ok=True)
233
+ image_grid.save(f"{test_dir}/{epoch:04d}.png")
234
+
235
+ """Now you can wrap all these components together in a training loop with 🤗 Accelerate for easy TensorBoard logging, gradient accumulation, and mixed precision training. To upload the model to the Hub, write a function to get your repository name and information and then push it to the Hub.
236
+ <Tip>
237
+ 💡 The training loop below may look intimidating and long, but it'll be worth it later when you launch your training in just one line of code! If you can't wait and want to start generating images, feel free to copy and run the code below. You can always come back and examine the training loop more closely later, like when you're waiting for your model to finish training. 🤗
238
+ </Tip>
239
+ """
240
+
241
+ from accelerate import Accelerator
242
+ from huggingface_hub import HfFolder, Repository, whoami
243
+ from tqdm.auto import tqdm
244
+ from pathlib import Path
245
+ import os
246
+
247
+
248
+ def get_full_repo_name(model_id: str, organization: str = None, token: str = None):
249
+ if token is None:
250
+ token = HfFolder.get_token()
251
+ if organization is None:
252
+ username = whoami(token)["name"]
253
+ return f"{username}/{model_id}"
254
+ else:
255
+ return f"{organization}/{model_id}"
256
+
257
+
258
+ def train_loop(config, model, noise_scheduler, optimizer, train_dataloader, lr_scheduler):
259
+ # Initialize accelerator and tensorboard logging
260
+ accelerator = Accelerator(
261
+ mixed_precision=config.mixed_precision,
262
+ gradient_accumulation_steps=config.gradient_accumulation_steps,
263
+ log_with="tensorboard",
264
+ project_dir=os.path.join(config.output_dir, "logs"),
265
+ )
266
+ if accelerator.is_main_process:
267
+ if config.push_to_hub:
268
+ repo_name = get_full_repo_name(Path(config.output_dir).name)
269
+ repo = Repository(config.output_dir, clone_from=repo_name)
270
+ elif config.output_dir is not None:
271
+ os.makedirs(config.output_dir, exist_ok=True)
272
+ accelerator.init_trackers("train_example")
273
+
274
+ # Prepare everything
275
+ # There is no specific order to remember, you just need to unpack the
276
+ # objects in the same order you gave them to the prepare method.
277
+ model, optimizer, train_dataloader, lr_scheduler = accelerator.prepare(
278
+ model, optimizer, train_dataloader, lr_scheduler
279
+ )
280
+
281
+ global_step = 0
282
+
283
+ # Now you train the model
284
+ for epoch in range(config.num_epochs):
285
+ progress_bar = tqdm(total=len(train_dataloader), disable=not accelerator.is_local_main_process)
286
+ progress_bar.set_description(f"Epoch {epoch}")
287
+
288
+ for step, batch in enumerate(train_dataloader):
289
+ clean_images = batch["images"]
290
+ # Sample noise to add to the images
291
+ noise = torch.randn(clean_images.shape).to(clean_images.device)
292
+ bs = clean_images.shape[0]
293
+
294
+ # Sample a random timestep for each image
295
+ timesteps = torch.randint(
296
+ 0, noise_scheduler.config.num_train_timesteps, (bs,), device=clean_images.device
297
+ ).long()
298
+
299
+ # Add noise to the clean images according to the noise magnitude at each timestep
300
+ # (this is the forward diffusion process)
301
+ noisy_images = noise_scheduler.add_noise(clean_images, noise, timesteps)
302
+
303
+ with accelerator.accumulate(model):
304
+ # Predict the noise residual
305
+ noise_pred = model(noisy_images, timesteps, return_dict=False)[0]
306
+ loss = F.mse_loss(noise_pred, noise)
307
+ accelerator.backward(loss)
308
+
309
+ accelerator.clip_grad_norm_(model.parameters(), 1.0)
310
+ optimizer.step()
311
+ lr_scheduler.step()
312
+ optimizer.zero_grad()
313
+
314
+ progress_bar.update(1)
315
+ logs = {"loss": loss.detach().item(), "lr": lr_scheduler.get_last_lr()[0], "step": global_step}
316
+ progress_bar.set_postfix(**logs)
317
+ accelerator.log(logs, step=global_step)
318
+ global_step += 1
319
+
320
+ # After each epoch you optionally sample some demo images with evaluate() and save the model
321
+ if accelerator.is_main_process:
322
+ pipeline = DDPMPipeline(unet=accelerator.unwrap_model(model), scheduler=noise_scheduler)
323
+
324
+ if (epoch + 1) % config.save_image_epochs == 0 or epoch == config.num_epochs - 1:
325
+ evaluate(config, epoch, pipeline)
326
+
327
+ if (epoch + 1) % config.save_model_epochs == 0 or epoch == config.num_epochs - 1:
328
+ if config.push_to_hub:
329
+ repo.push_to_hub(commit_message=f"Epoch {epoch}", blocking=True)
330
+ else:
331
+ pipeline.save_pretrained(config.output_dir)
332
+
333
+ """Phew, that was quite a bit of code! But you're finally ready to launch the training with 🤗 Accelerate's [notebook_launcher](https://huggingface.co/docs/accelerate/main/en/package_reference/launchers#accelerate.notebook_launcher) function. Pass the function the training loop, all the training arguments, and the number of processes (you can change this value to the number of GPUs available to you) to use for training:"""
334
+
335
+ #!/usr/local/cuda/bin/nvcc --version
336
+
337
+ #!nvidia-smi
338
+
339
+ from accelerate import notebook_launcher
340
+
341
+
342
+ args = (config, model, noise_scheduler, optimizer, train_dataloader, lr_scheduler)
343
+ #print(model)
344
+
345
+ notebook_launcher(train_loop, args, num_processes=1)
346
+
347
+ """Once training is complete, take a look at the final 🦋 images 🦋 generated by your diffusion model!"""
348
+
349
+ import glob
350
+
351
+ sample_images = sorted(glob.glob(f"{config.output_dir}/samples/*.png"))
352
+ Image.open(sample_images[-1])