Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 0b6eb7ce5e | |||
| fa3afbcae1 | |||
| f26f793937 | |||
| 61864e192a |
@@ -1,4 +1,4 @@
|
|||||||
# PromptSRC: Prompting with Self-regularizing constraints
|
# DZGCoOp: Dual-branch Zero-shot Guidance CoOp
|
||||||
DATALOADER:
|
DATALOADER:
|
||||||
TRAIN_X:
|
TRAIN_X:
|
||||||
BATCH_SIZE: 4
|
BATCH_SIZE: 4
|
||||||
@@ -30,14 +30,15 @@ MODEL:
|
|||||||
NAME: "ViT-B/16"
|
NAME: "ViT-B/16"
|
||||||
|
|
||||||
TRAINER:
|
TRAINER:
|
||||||
PROMPTSRC:
|
DZGCOOP:
|
||||||
N_CTX_VISION: 4
|
N_CTX_VISION: 4
|
||||||
N_CTX_TEXT: 4
|
N_CTX_TEXT: 4
|
||||||
CTX_INIT: "a photo of a"
|
CTX_INIT: "a photo of a"
|
||||||
PREC: "fp16"
|
PREC: "fp16"
|
||||||
PROMPT_DEPTH_VISION: 9
|
PROMPT_DEPTH_VISION: 9
|
||||||
PROMPT_DEPTH_TEXT: 9
|
PROMPT_DEPTH_TEXT: 9
|
||||||
TEXT_LOSS_WEIGHT: 25
|
IMAGE_LOSS_WEIGHT: 8
|
||||||
IMAGE_LOSS_WEIGHT: 10
|
TEXT_LOSS_WEIGHT_STRONG: 24
|
||||||
GPA_MEAN: 15
|
TEXT_LOSS_WEIGHT_WEAK: 8
|
||||||
GPA_STD: 1
|
EWA_MEAN: 15
|
||||||
|
EWA_STD: 1
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
# PromptSRC: Prompting with Self-regularizing constraints
|
# DZGCoOp: Dual-branch Zero-shot Guidance CoOp
|
||||||
DATALOADER:
|
DATALOADER:
|
||||||
TRAIN_X:
|
TRAIN_X:
|
||||||
BATCH_SIZE: 4
|
BATCH_SIZE: 4
|
||||||
@@ -31,7 +31,7 @@ MODEL:
|
|||||||
NAME: "ViT-B/16"
|
NAME: "ViT-B/16"
|
||||||
|
|
||||||
TRAINER:
|
TRAINER:
|
||||||
PROMPTSRC:
|
DZGCOOP:
|
||||||
N_CTX_VISION: 4
|
N_CTX_VISION: 4
|
||||||
N_CTX_TEXT: 4
|
N_CTX_TEXT: 4
|
||||||
CTX_INIT: "a photo of a"
|
CTX_INIT: "a photo of a"
|
||||||
@@ -40,5 +40,5 @@ TRAINER:
|
|||||||
PROMPT_DEPTH_TEXT: 3
|
PROMPT_DEPTH_TEXT: 3
|
||||||
TEXT_LOSS_WEIGHT: 25
|
TEXT_LOSS_WEIGHT: 25
|
||||||
IMAGE_LOSS_WEIGHT: 10
|
IMAGE_LOSS_WEIGHT: 10
|
||||||
GPA_MEAN: 6
|
EWA_MEAN: 6
|
||||||
GPA_STD: 10
|
EWA_STD: 10
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
# PromptSRC: Prompting with Self-regularizing constraints
|
# DZGCoOp: Dual-branch Zero-shot Guidance CoOp
|
||||||
DATALOADER:
|
DATALOADER:
|
||||||
TRAIN_X:
|
TRAIN_X:
|
||||||
BATCH_SIZE: 4
|
BATCH_SIZE: 4
|
||||||
@@ -30,7 +30,7 @@ MODEL:
|
|||||||
NAME: "ViT-B/16"
|
NAME: "ViT-B/16"
|
||||||
|
|
||||||
TRAINER:
|
TRAINER:
|
||||||
PROMPTSRC:
|
DZGCOOP:
|
||||||
N_CTX_VISION: 4
|
N_CTX_VISION: 4
|
||||||
N_CTX_TEXT: 4
|
N_CTX_TEXT: 4
|
||||||
CTX_INIT: "a photo of a"
|
CTX_INIT: "a photo of a"
|
||||||
@@ -39,5 +39,5 @@ TRAINER:
|
|||||||
PROMPT_DEPTH_TEXT: 3
|
PROMPT_DEPTH_TEXT: 3
|
||||||
TEXT_LOSS_WEIGHT: 25
|
TEXT_LOSS_WEIGHT: 25
|
||||||
IMAGE_LOSS_WEIGHT: 10
|
IMAGE_LOSS_WEIGHT: 10
|
||||||
GPA_MEAN: 6
|
EWA_MEAN: 6
|
||||||
GPA_STD: 10
|
EWA_STD: 10
|
||||||
@@ -11,7 +11,7 @@ Training PromptSRC on ImageNet for 20 epochs takes around 6 hours for a single s
|
|||||||
## PromptSRC
|
## PromptSRC
|
||||||
|
|
||||||
#### (1) Base-to-Novel class generalization setting
|
#### (1) Base-to-Novel class generalization setting
|
||||||
The base-to-novel PromptSRC configuration is provided in config file at `configs/trainers/PromptSRC/vit_b16_c2_ep20_batch4_4+4ctx.yaml`. All hyper-parameters such as GPA STD, GPA Mean, SCL loss weights coefficients, prompt length and prompt depth etc., can be modified using this config file.
|
The base-to-novel PromptSRC configuration is provided in config file at `configs/trainers/PromptSRC/vit_b16_c2_ep20_batch4_4+4ctx.yaml`. All hyper-parameters such as EWA STD, EWA Mean, SCL loss weights coefficients, prompt length and prompt depth etc., can be modified using this config file.
|
||||||
|
|
||||||
Run the commands below to train PromptSRC on ImageNet.
|
Run the commands below to train PromptSRC on ImageNet.
|
||||||
|
|
||||||
|
|||||||
@@ -109,7 +109,7 @@ def print_model_results(results, model_name):
|
|||||||
|
|
||||||
def main():
|
def main():
|
||||||
root_dir = 'output' # 修改为你的output目录路径
|
root_dir = 'output' # 修改为你的output目录路径
|
||||||
target_model = 'PromptSRC' # 指定要分析的模型
|
target_model = 'DZGCoOp' # 指定要分析的模型
|
||||||
|
|
||||||
results = collect_model_results(root_dir, target_model)
|
results = collect_model_results(root_dir, target_model)
|
||||||
print_model_results(results, target_model)
|
print_model_results(results, target_model)
|
||||||
|
|||||||
22
scripts/dzgcoop/base2new_all.sh
Normal file
22
scripts/dzgcoop/base2new_all.sh
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
seeds=(1 2 3)
|
||||||
|
datasets=(
|
||||||
|
"ucf101"
|
||||||
|
"eurosat"
|
||||||
|
"oxford_pets"
|
||||||
|
"food101"
|
||||||
|
"oxford_flowers"
|
||||||
|
"dtd"
|
||||||
|
"caltech101"
|
||||||
|
"fgvc_aircraft"
|
||||||
|
"stanford_cars"
|
||||||
|
"sun397"
|
||||||
|
# "imagenet"
|
||||||
|
)
|
||||||
|
|
||||||
|
for dataset in "${datasets[@]}"; do
|
||||||
|
for seed in "${seeds[@]}"; do
|
||||||
|
bash scripts/dzgcoop/base2new_train.sh "$dataset" "$seed"
|
||||||
|
bash scripts/dzgcoop/base2new_test.sh "$dataset" "$seed"
|
||||||
|
done
|
||||||
|
done
|
||||||
|
|
||||||
@@ -3,7 +3,7 @@
|
|||||||
|
|
||||||
# custom config
|
# custom config
|
||||||
DATA="~/Datasets/CoOp"
|
DATA="~/Datasets/CoOp"
|
||||||
TRAINER=PromptSRC
|
TRAINER=DZGCoOp
|
||||||
|
|
||||||
DATASET=$1
|
DATASET=$1
|
||||||
SEED=$2
|
SEED=$2
|
||||||
@@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
# custom config
|
# custom config
|
||||||
DATA="~/Datasets/CoOp"
|
DATA="~/Datasets/CoOp"
|
||||||
TRAINER=PromptSRC
|
TRAINER=DZGCoOp
|
||||||
|
|
||||||
DATASET=$1
|
DATASET=$1
|
||||||
SEED=$2
|
SEED=$2
|
||||||
@@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
|
|
||||||
DATA=" ~/Datasets/CoOp"
|
DATA=" ~/Datasets/CoOp"
|
||||||
TRAINER=PromptSRC
|
TRAINER=DZGCoOp
|
||||||
SRC_DATASETS=imagenet
|
SRC_DATASETS=imagenet
|
||||||
SHOTS=16
|
SHOTS=16
|
||||||
CFG=vit_b16_c2_ep20_batch4_4+4ctx_cross_datasets
|
CFG=vit_b16_c2_ep20_batch4_4+4ctx_cross_datasets
|
||||||
@@ -3,7 +3,7 @@
|
|||||||
|
|
||||||
# custom config
|
# custom config
|
||||||
DATA=" ~/Datasets/CoOp"
|
DATA=" ~/Datasets/CoOp"
|
||||||
TRAINER=PromptSRC
|
TRAINER=DZGCoOp
|
||||||
|
|
||||||
|
|
||||||
SRC_DATASETS=imagenet
|
SRC_DATASETS=imagenet
|
||||||
@@ -3,7 +3,7 @@
|
|||||||
|
|
||||||
# custom config
|
# custom config
|
||||||
DATA=" ~/Datasets/CoOp"
|
DATA=" ~/Datasets/CoOp"
|
||||||
TRAINER=PromptSRC
|
TRAINER=DZGCoOp
|
||||||
|
|
||||||
|
|
||||||
SRC_DATASETS=imagenet
|
SRC_DATASETS=imagenet
|
||||||
@@ -1,22 +0,0 @@
|
|||||||
seeds=(1 2 3)
|
|
||||||
datasets=(
|
|
||||||
# "ucf101"
|
|
||||||
# "eurosat"
|
|
||||||
# "oxford_pets"
|
|
||||||
# "food101"
|
|
||||||
# "oxford_flowers"
|
|
||||||
# "dtd"
|
|
||||||
# "caltech101"
|
|
||||||
# "fgvc_aircraft"
|
|
||||||
# "stanford_cars"
|
|
||||||
# "sun397"
|
|
||||||
"imagenet"
|
|
||||||
)
|
|
||||||
|
|
||||||
for dataset in "${datasets[@]}"; do
|
|
||||||
for seed in "${seeds[@]}"; do
|
|
||||||
bash scripts/promptsrc/base2new_train.sh "$dataset" "$seed"
|
|
||||||
bash scripts/promptsrc/base2new_test.sh "$dataset" "$seed"
|
|
||||||
done
|
|
||||||
done
|
|
||||||
|
|
||||||
29
train.py
29
train.py
@@ -28,7 +28,7 @@ import trainers.cocoop
|
|||||||
import trainers.zsclip
|
import trainers.zsclip
|
||||||
import trainers.maple
|
import trainers.maple
|
||||||
import trainers.independentVL
|
import trainers.independentVL
|
||||||
import trainers.promptsrc
|
import trainers.dzgcoop
|
||||||
|
|
||||||
|
|
||||||
def print_args(args, cfg):
|
def print_args(args, cfg):
|
||||||
@@ -110,20 +110,19 @@ def extend_cfg(cfg):
|
|||||||
cfg.TRAINER.MAPLE.PROMPT_DEPTH = 9 # Max 12, minimum 0, for 1 it will act as shallow MaPLe (J=1)
|
cfg.TRAINER.MAPLE.PROMPT_DEPTH = 9 # Max 12, minimum 0, for 1 it will act as shallow MaPLe (J=1)
|
||||||
cfg.DATASET.SUBSAMPLE_CLASSES = "all" # all, base or new
|
cfg.DATASET.SUBSAMPLE_CLASSES = "all" # all, base or new
|
||||||
|
|
||||||
# Config for PromptSRC
|
# Config for DZGCoOp
|
||||||
cfg.TRAINER.PROMPTSRC = CN()
|
cfg.TRAINER.DZGCOOP = CN()
|
||||||
cfg.TRAINER.PROMPTSRC.N_CTX_VISION = 4 # number of context vectors at the vision branch
|
cfg.TRAINER.DZGCOOP.N_CTX_VISION = 4 # number of context vectors at the vision branch
|
||||||
cfg.TRAINER.PROMPTSRC.N_CTX_TEXT = 4 # number of context vectors at the language branch
|
cfg.TRAINER.DZGCOOP.N_CTX_TEXT = 4 # number of context vectors at the language branch
|
||||||
cfg.TRAINER.PROMPTSRC.CTX_INIT = "a photo of a" # initialization words
|
cfg.TRAINER.DZGCOOP.CTX_INIT = "a photo of a" # initialization words
|
||||||
cfg.TRAINER.PROMPTSRC.PREC = "fp16" # fp16, fp32, amp
|
cfg.TRAINER.DZGCOOP.PREC = "fp16" # fp16, fp32, amp
|
||||||
cfg.TRAINER.PROMPTSRC.PROMPT_DEPTH_VISION = 9 # Max 12, minimum 0, for 0 it will be using shallow IVLP prompting (J=1)
|
cfg.TRAINER.DZGCOOP.PROMPT_DEPTH_VISION = 9 # Max 12, minimum 0, for 0 it will be using shallow IVLP prompting (J=1)
|
||||||
cfg.TRAINER.PROMPTSRC.PROMPT_DEPTH_TEXT = 9 # Max 12, minimum 0, for 0 it will be using shallow IVLP prompting (J=1)
|
cfg.TRAINER.DZGCOOP.PROMPT_DEPTH_TEXT = 9 # Max 12, minimum 0, for 0 it will be using shallow IVLP prompting (J=1)
|
||||||
cfg.TRAINER.PROMPTSRC.TEXT_LOSS_WEIGHT = 25
|
cfg.TRAINER.DZGCOOP.TEXT_LOSS_WEIGHT_STRONG = 25 # lambda2: strong text constraint weight
|
||||||
cfg.TRAINER.PROMPTSRC.TEXT_LOSS_WEIGHT_STRONG = 25 # lambda2: strong text constraint weight
|
cfg.TRAINER.DZGCOOP.TEXT_LOSS_WEIGHT_WEAK = 10 # lambda3: weak text constraint weight
|
||||||
cfg.TRAINER.PROMPTSRC.TEXT_LOSS_WEIGHT_WEAK = 2.5 # lambda3: weak text constraint weight
|
cfg.TRAINER.DZGCOOP.IMAGE_LOSS_WEIGHT = 10
|
||||||
cfg.TRAINER.PROMPTSRC.IMAGE_LOSS_WEIGHT = 10
|
cfg.TRAINER.DZGCOOP.EWA_MEAN = 15
|
||||||
cfg.TRAINER.PROMPTSRC.GPA_MEAN = 15
|
cfg.TRAINER.DZGCOOP.EWA_STD = 1
|
||||||
cfg.TRAINER.PROMPTSRC.GPA_STD = 1
|
|
||||||
cfg.DATASET.SUBSAMPLE_CLASSES = "all" # all, base or new
|
cfg.DATASET.SUBSAMPLE_CLASSES = "all" # all, base or new
|
||||||
|
|
||||||
# Config for independent Vision Language prompting (independent-vlp)
|
# Config for independent Vision Language prompting (independent-vlp)
|
||||||
|
|||||||
@@ -51,10 +51,10 @@ def load_clip_to_cpu(cfg, zero_shot_model=False):
|
|||||||
state_dict = torch.load(model_path, map_location="cpu")
|
state_dict = torch.load(model_path, map_location="cpu")
|
||||||
if not zero_shot_model:
|
if not zero_shot_model:
|
||||||
design_details = {"trainer": 'IVLP',
|
design_details = {"trainer": 'IVLP',
|
||||||
"vision_depth": cfg.TRAINER.PROMPTSRC.PROMPT_DEPTH_VISION,
|
"vision_depth": cfg.TRAINER.DZGCOOP.PROMPT_DEPTH_VISION,
|
||||||
"language_depth": cfg.TRAINER.PROMPTSRC.PROMPT_DEPTH_TEXT,
|
"language_depth": cfg.TRAINER.DZGCOOP.PROMPT_DEPTH_TEXT,
|
||||||
"vision_ctx": cfg.TRAINER.PROMPTSRC.N_CTX_VISION,
|
"vision_ctx": cfg.TRAINER.DZGCOOP.N_CTX_VISION,
|
||||||
"language_ctx": cfg.TRAINER.PROMPTSRC.N_CTX_TEXT}
|
"language_ctx": cfg.TRAINER.DZGCOOP.N_CTX_TEXT}
|
||||||
model = clip.build_model(state_dict or model.state_dict(), design_details)
|
model = clip.build_model(state_dict or model.state_dict(), design_details)
|
||||||
else:
|
else:
|
||||||
# Return original CLIP model for generating frozen VL features
|
# Return original CLIP model for generating frozen VL features
|
||||||
@@ -95,11 +95,11 @@ class VLPromptLearner(nn.Module):
|
|||||||
super().__init__()
|
super().__init__()
|
||||||
n_cls = len(classnames)
|
n_cls = len(classnames)
|
||||||
# Make sure Language depth >= 1
|
# Make sure Language depth >= 1
|
||||||
assert cfg.TRAINER.PROMPTSRC.PROMPT_DEPTH_TEXT >= 1, "In Independent VL prompting, Language prompt depth should be >=1" \
|
assert cfg.TRAINER.DZGCOOP.PROMPT_DEPTH_TEXT >= 1, "In Independent VL prompting, Language prompt depth should be >=1" \
|
||||||
"\nPlease use VPT trainer if you want to learn only vision " \
|
"\nPlease use VPT trainer if you want to learn only vision " \
|
||||||
"branch"
|
"branch"
|
||||||
n_ctx = cfg.TRAINER.PROMPTSRC.N_CTX_TEXT
|
n_ctx = cfg.TRAINER.DZGCOOP.N_CTX_TEXT
|
||||||
ctx_init = cfg.TRAINER.PROMPTSRC.CTX_INIT
|
ctx_init = cfg.TRAINER.DZGCOOP.CTX_INIT
|
||||||
dtype = clip_model.dtype
|
dtype = clip_model.dtype
|
||||||
ctx_dim = clip_model.ln_final.weight.shape[0]
|
ctx_dim = clip_model.ln_final.weight.shape[0]
|
||||||
clip_imsize = clip_model.visual.input_resolution
|
clip_imsize = clip_model.visual.input_resolution
|
||||||
@@ -126,7 +126,7 @@ class VLPromptLearner(nn.Module):
|
|||||||
print(f'Strong branch initial text context: "{prompt_prefix_strong}"')
|
print(f'Strong branch initial text context: "{prompt_prefix_strong}"')
|
||||||
print(f'Weak branch initial text context: "{prompt_prefix_weak}"')
|
print(f'Weak branch initial text context: "{prompt_prefix_weak}"')
|
||||||
print(f"Number of context words (tokens) for Language prompting: {n_ctx}")
|
print(f"Number of context words (tokens) for Language prompting: {n_ctx}")
|
||||||
print(f"Number of context words (tokens) for Vision prompting: {cfg.TRAINER.PROMPTSRC.N_CTX_VISION}")
|
print(f"Number of context words (tokens) for Vision prompting: {cfg.TRAINER.DZGCOOP.N_CTX_VISION}")
|
||||||
self.ctx_strong = nn.Parameter(ctx_vectors_strong)
|
self.ctx_strong = nn.Parameter(ctx_vectors_strong)
|
||||||
self.ctx_weak = nn.Parameter(ctx_vectors_weak)
|
self.ctx_weak = nn.Parameter(ctx_vectors_weak)
|
||||||
|
|
||||||
@@ -142,7 +142,7 @@ class VLPromptLearner(nn.Module):
|
|||||||
embedding = clip_model.token_embedding(tokenized_prompts).type(dtype)
|
embedding = clip_model.token_embedding(tokenized_prompts).type(dtype)
|
||||||
self.ZS_image_encoder = clip_model_temp_image.visual
|
self.ZS_image_encoder = clip_model_temp_image.visual
|
||||||
# Now pre-compute the frozen VL embeddings from LLM descriptions
|
# Now pre-compute the frozen VL embeddings from LLM descriptions
|
||||||
all_teacher_features = []
|
semantic_guidance_features = []
|
||||||
desc_file = f"./desc/{DESC_LLM}/descriptions_top{DESC_TOPK}/{cfg.DATASET.NAME}.json"
|
desc_file = f"./desc/{DESC_LLM}/descriptions_top{DESC_TOPK}/{cfg.DATASET.NAME}.json"
|
||||||
with open(desc_file, "r") as f:
|
with open(desc_file, "r") as f:
|
||||||
all_desc = json.load(f)
|
all_desc = json.load(f)
|
||||||
@@ -155,9 +155,9 @@ class VLPromptLearner(nn.Module):
|
|||||||
cls_feature = clip_model_temp.encode_text(cls_token)
|
cls_feature = clip_model_temp.encode_text(cls_token)
|
||||||
cls_feature = cls_feature / cls_feature.norm(dim=-1, keepdim=True)
|
cls_feature = cls_feature / cls_feature.norm(dim=-1, keepdim=True)
|
||||||
cls_feature = torch.mean(cls_feature, dim=0)
|
cls_feature = torch.mean(cls_feature, dim=0)
|
||||||
all_teacher_features.append(cls_feature)
|
semantic_guidance_features.append(cls_feature)
|
||||||
|
|
||||||
self.fixed_embeddings = torch.stack(all_teacher_features)
|
self.semantic_embeddings = torch.stack(semantic_guidance_features)
|
||||||
print(f"Using LLM descriptions from: {desc_file}")
|
print(f"Using LLM descriptions from: {desc_file}")
|
||||||
# These token vectors will be saved when in save_model(),
|
# These token vectors will be saved when in save_model(),
|
||||||
# but they should be ignored in load_model() as we want to use
|
# but they should be ignored in load_model() as we want to use
|
||||||
@@ -238,10 +238,10 @@ class CustomCLIP(nn.Module):
|
|||||||
text_features_weak = self.text_encoder(prompts_weak, tokenized_prompts)
|
text_features_weak = self.text_encoder(prompts_weak, tokenized_prompts)
|
||||||
text_features_weak = text_features_weak / text_features_weak.norm(dim=-1, keepdim=True)
|
text_features_weak = text_features_weak / text_features_weak.norm(dim=-1, keepdim=True)
|
||||||
|
|
||||||
fixed_embeddings = self.prompt_learner.fixed_embeddings
|
semantic_embeddings = self.prompt_learner.semantic_embeddings
|
||||||
fixed_embeddings = fixed_embeddings / fixed_embeddings.norm(dim=-1, keepdim=True)
|
semantic_embeddings = semantic_embeddings / semantic_embeddings.norm(dim=-1, keepdim=True)
|
||||||
|
|
||||||
zero_shot_logits = logit_scale * zero_shot_features.cuda() @ fixed_embeddings.half().cuda().t()
|
zero_shot_logits = logit_scale * zero_shot_features.cuda() @ semantic_embeddings.half().cuda().t()
|
||||||
|
|
||||||
logits_strong = logit_scale * image_features @ text_features_strong.t()
|
logits_strong = logit_scale * image_features @ text_features_strong.t()
|
||||||
logits_weak = logit_scale * image_features @ text_features_weak.t()
|
logits_weak = logit_scale * image_features @ text_features_weak.t()
|
||||||
@@ -255,15 +255,15 @@ class CustomCLIP(nn.Module):
|
|||||||
|
|
||||||
if self.prompt_learner.training:
|
if self.prompt_learner.training:
|
||||||
loss_ce = F.cross_entropy(logits_final, label)
|
loss_ce = F.cross_entropy(logits_final, label)
|
||||||
return loss_ce, text_features_strong, text_features_weak, fixed_embeddings, zero_shot_features, image_features, zero_shot_logits, logits_strong, logits_weak, logits_final
|
return loss_ce, text_features_strong, text_features_weak, semantic_embeddings, zero_shot_features, image_features, zero_shot_logits, logits_strong, logits_weak, logits_final
|
||||||
else:
|
else:
|
||||||
return logits_final
|
return logits_final
|
||||||
|
|
||||||
|
|
||||||
@TRAINER_REGISTRY.register()
|
@TRAINER_REGISTRY.register()
|
||||||
class PromptSRC(TrainerX):
|
class DZGCoOp(TrainerX):
|
||||||
def check_cfg(self, cfg):
|
def check_cfg(self, cfg):
|
||||||
assert cfg.TRAINER.PROMPTSRC.PREC in ["fp16", "fp32", "amp"]
|
assert cfg.TRAINER.DZGCOOP.PREC in ["fp16", "fp32", "amp"]
|
||||||
|
|
||||||
def build_model(self):
|
def build_model(self):
|
||||||
cfg = self.cfg
|
cfg = self.cfg
|
||||||
@@ -272,7 +272,7 @@ class PromptSRC(TrainerX):
|
|||||||
print(f"Loading CLIP (backbone: {cfg.MODEL.BACKBONE.NAME})")
|
print(f"Loading CLIP (backbone: {cfg.MODEL.BACKBONE.NAME})")
|
||||||
clip_model = load_clip_to_cpu(cfg)
|
clip_model = load_clip_to_cpu(cfg)
|
||||||
|
|
||||||
if cfg.TRAINER.PROMPTSRC.PREC == "fp32" or cfg.TRAINER.PROMPTSRC.PREC == "amp":
|
if cfg.TRAINER.DZGCOOP.PREC == "fp32" or cfg.TRAINER.DZGCOOP.PREC == "amp":
|
||||||
# CLIP's default precision is fp16
|
# CLIP's default precision is fp16
|
||||||
clip_model.float()
|
clip_model.float()
|
||||||
|
|
||||||
@@ -312,20 +312,20 @@ class PromptSRC(TrainerX):
|
|||||||
self.total_epochs = cfg.OPTIM.MAX_EPOCH
|
self.total_epochs = cfg.OPTIM.MAX_EPOCH
|
||||||
self.step_counter = 1
|
self.step_counter = 1
|
||||||
N = cfg.OPTIM.MAX_EPOCH
|
N = cfg.OPTIM.MAX_EPOCH
|
||||||
mean = cfg.TRAINER.PROMPTSRC.GPA_MEAN
|
mean = cfg.TRAINER.DZGCOOP.EWA_MEAN
|
||||||
stdev = cfg.TRAINER.PROMPTSRC.GPA_STD
|
stdev = cfg.TRAINER.DZGCOOP.EWA_STD
|
||||||
gauss = self.get_gauss(mean, stdev)
|
normal = self.get_normal(mean, stdev)
|
||||||
self.gauss = np.array([gauss(a) for a in range(1, N + 1)])
|
self.normal_weights = np.array([normal(a) for a in range(1, N + 1)])
|
||||||
self.gauss = self.gauss / sum(self.gauss)
|
self.normal_weights = self.normal_weights / sum(self.normal_weights)
|
||||||
self.scaler = GradScaler() if cfg.TRAINER.PROMPTSRC.PREC == "amp" else None
|
self.scaler = GradScaler() if cfg.TRAINER.DZGCOOP.PREC == "amp" else None
|
||||||
# Note that multi-gpu training could be slow because CLIP's size is
|
# Note that multi-gpu training could be slow because CLIP's size is
|
||||||
# big, which slows down the copy operation in DataParallel
|
# big, which slows down the copy operation in DataParallel
|
||||||
device_count = torch.cuda.device_count()
|
device_count = torch.cuda.device_count()
|
||||||
if device_count > 1:
|
if device_count > 1:
|
||||||
print(f"Multiple GPUs detected (n_gpus={device_count}), use all of them!")
|
print(f"Multiple GPUs detected (n_gpus={device_count}), use all of them!")
|
||||||
self.model = nn.DataParallel(self.model)
|
self.model = nn.DataParallel(self.model)
|
||||||
# Keep model with GPA
|
# Keep model with EWA
|
||||||
self.previous_model_gpa = None
|
self.previous_model_ewa = None
|
||||||
|
|
||||||
def forward_backward(self, batch):
|
def forward_backward(self, batch):
|
||||||
image, label = self.parse_batch_train(batch)
|
image, label = self.parse_batch_train(batch)
|
||||||
@@ -334,7 +334,7 @@ class PromptSRC(TrainerX):
|
|||||||
optim = self.optim
|
optim = self.optim
|
||||||
scaler = self.scaler
|
scaler = self.scaler
|
||||||
|
|
||||||
prec = self.cfg.TRAINER.PROMPTSRC.PREC
|
prec = self.cfg.TRAINER.DZGCOOP.PREC
|
||||||
if prec == "amp":
|
if prec == "amp":
|
||||||
with autocast():
|
with autocast():
|
||||||
loss = model(image, label)
|
loss = model(image, label)
|
||||||
@@ -343,26 +343,26 @@ class PromptSRC(TrainerX):
|
|||||||
scaler.step(optim)
|
scaler.step(optim)
|
||||||
scaler.update()
|
scaler.update()
|
||||||
else:
|
else:
|
||||||
loss_ce, text_features_strong, text_features_weak, fixed_embeddings, zs_image_embedd, image_ft, \
|
loss_ce, text_features_strong, text_features_weak, semantic_embeddings, zs_image_embedd, image_ft, \
|
||||||
zero_shot_logits, logits_strong, logits_weak, logits_final = model(image, label)
|
zero_shot_logits, logits_strong, logits_weak, logits_final = model(image, label)
|
||||||
|
|
||||||
lambda1 = self.cfg.TRAINER.PROMPTSRC.IMAGE_LOSS_WEIGHT
|
lambda1 = self.cfg.TRAINER.DZGCOOP.IMAGE_LOSS_WEIGHT
|
||||||
lambda2 = self.cfg.TRAINER.PROMPTSRC.TEXT_LOSS_WEIGHT_STRONG
|
lambda2 = self.cfg.TRAINER.DZGCOOP.TEXT_LOSS_WEIGHT_STRONG
|
||||||
lambda3 = self.cfg.TRAINER.PROMPTSRC.TEXT_LOSS_WEIGHT_WEAK
|
lambda3 = self.cfg.TRAINER.DZGCOOP.TEXT_LOSS_WEIGHT_WEAK
|
||||||
|
|
||||||
loss_scl_image = F.l1_loss(image_ft, zs_image_embedd.cuda(), reduction='mean') * lambda1
|
L_zvg = F.l1_loss(image_ft, zs_image_embedd.cuda(), reduction='mean') * lambda1
|
||||||
loss_scl_text_strong = F.l1_loss(text_features_strong, fixed_embeddings.cuda(), reduction='mean') * lambda2
|
L_sg_strong = F.l1_loss(text_features_strong, semantic_embeddings.cuda(), reduction='mean') * lambda2
|
||||||
loss_scl_text_weak = F.l1_loss(text_features_weak, fixed_embeddings.cuda(), reduction='mean') * lambda3
|
L_sg_weak = F.l1_loss(text_features_weak, semantic_embeddings.cuda(), reduction='mean') * lambda3
|
||||||
|
|
||||||
L_SCL_logits = F.kl_div(
|
L_zpg = F.kl_div(
|
||||||
F.log_softmax(logits_final / 1, dim=1),
|
F.log_softmax(logits_final / 1, dim=1),
|
||||||
F.log_softmax(zero_shot_logits / 1, dim=1),
|
F.log_softmax(zero_shot_logits / 1, dim=1),
|
||||||
reduction='sum',
|
reduction='sum',
|
||||||
log_target=True
|
log_target=True
|
||||||
) * (1 * 1) / logits_final.numel()
|
) * (1 * 1) / logits_final.numel()
|
||||||
|
|
||||||
L_SCL = (L_SCL_logits + loss_scl_text_strong + loss_scl_text_weak + loss_scl_image)
|
L_zg = (L_zpg + L_sg_strong + L_sg_weak + L_zvg)
|
||||||
loss = (loss_ce + L_SCL)
|
loss = (loss_ce + L_zg)
|
||||||
optim.zero_grad()
|
optim.zero_grad()
|
||||||
loss.backward()
|
loss.backward()
|
||||||
optim.step()
|
optim.step()
|
||||||
@@ -371,20 +371,22 @@ class PromptSRC(TrainerX):
|
|||||||
|
|
||||||
if (self.batch_idx + 1) == self.num_batches:
|
if (self.batch_idx + 1) == self.num_batches:
|
||||||
self.update_lr()
|
self.update_lr()
|
||||||
# Means one epoch is completed, perform GPA
|
# Means one epoch is completed, perform EWA
|
||||||
self.step_counter = self.step_counter + 1
|
self.step_counter = self.step_counter + 1
|
||||||
current_epoch_weight = self.gauss[self.step_counter - 2]
|
current_epoch_weight = self.normal_weights[self.step_counter - 2]
|
||||||
current_model_weights = copy.deepcopy(model.state_dict())
|
current_model_weights = copy.deepcopy(model.state_dict())
|
||||||
|
for key in current_model_weights:
|
||||||
|
current_model_weights[key] = current_model_weights[key].cpu()
|
||||||
weighted_state_dict = self.state_dict_weighting(current_model_weights, current_epoch_weight)
|
weighted_state_dict = self.state_dict_weighting(current_model_weights, current_epoch_weight)
|
||||||
if self.previous_model_gpa is None:
|
if self.previous_model_ewa is None:
|
||||||
self.previous_model_gpa = weighted_state_dict
|
self.previous_model_ewa = weighted_state_dict
|
||||||
else:
|
else:
|
||||||
self.previous_model_gpa = self.state_dict_add(weighted_state_dict, self.previous_model_gpa)
|
self.previous_model_ewa = self.state_dict_add(weighted_state_dict, self.previous_model_ewa)
|
||||||
|
|
||||||
if self.step_counter == self.model.total_epochs + 1:
|
if self.step_counter == self.model.total_epochs + 1:
|
||||||
print("Using GPA model for final inference...")
|
print("Using EWA model for final inference...")
|
||||||
model.load_state_dict(self.previous_model_gpa)
|
model.load_state_dict(self.previous_model_ewa)
|
||||||
self.model.load_state_dict(self.previous_model_gpa)
|
self.model.load_state_dict(self.previous_model_ewa)
|
||||||
return loss_summary
|
return loss_summary
|
||||||
|
|
||||||
def state_dict_weighting(self, main_dict, weightage, prompt_only=False):
|
def state_dict_weighting(self, main_dict, weightage, prompt_only=False):
|
||||||
@@ -392,24 +394,24 @@ class PromptSRC(TrainerX):
|
|||||||
updated_dict = copy.deepcopy(main_dict)
|
updated_dict = copy.deepcopy(main_dict)
|
||||||
if not prompt_only:
|
if not prompt_only:
|
||||||
for key in main_dict:
|
for key in main_dict:
|
||||||
updated_dict[key] = main_dict[key] * weightage
|
updated_dict[key] = main_dict[key].cpu() * weightage
|
||||||
return updated_dict
|
return updated_dict
|
||||||
else:
|
else:
|
||||||
return main_dict * weightage
|
return main_dict.cpu() * weightage
|
||||||
|
|
||||||
def state_dict_add(self, dict1, dict2, prompt_only=False):
|
def state_dict_add(self, dict1, dict2, prompt_only=False):
|
||||||
# Average all parameters
|
# Average all parameters
|
||||||
if not prompt_only:
|
if not prompt_only:
|
||||||
modified_dict = dict2
|
modified_dict = dict2
|
||||||
for key in dict1:
|
for key in dict1:
|
||||||
modified_dict[key] = (modified_dict[key] + dict1[key])
|
modified_dict[key] = modified_dict[key].cpu() + dict1[key].cpu()
|
||||||
return modified_dict
|
return modified_dict
|
||||||
else:
|
else:
|
||||||
return dict1 + dict2
|
return dict1.cpu() + dict2.cpu()
|
||||||
|
|
||||||
def get_gauss(self, mu, sigma):
|
def get_normal(self, mu, sigma):
|
||||||
gauss = lambda x: (1 / (sigma * np.sqrt(2 * np.pi))) * np.exp(-0.5 * ((x - mu) / sigma) ** 2)
|
normal = lambda x: (1 / (sigma * np.sqrt(2 * np.pi))) * np.exp(-0.5 * ((x - mu) / sigma) ** 2)
|
||||||
return gauss
|
return normal
|
||||||
|
|
||||||
def parse_batch_train(self, batch):
|
def parse_batch_train(self, batch):
|
||||||
input = batch["img"]
|
input = batch["img"]
|
||||||
@@ -456,4 +458,4 @@ class PromptSRC(TrainerX):
|
|||||||
|
|
||||||
print("Loading weights to {} " 'from "{}" (epoch = {})'.format(name, model_path, epoch))
|
print("Loading weights to {} " 'from "{}" (epoch = {})'.format(name, model_path, epoch))
|
||||||
# set strict=False
|
# set strict=False
|
||||||
self._models[name].load_state_dict(state_dict, strict=False)
|
self._models[name].load_state_dict(state_dict, strict=False)
|
||||||
Reference in New Issue
Block a user