Przeglądaj źródła

Fix issue with generating on multiple GPUs

81300 3 lat temu
rodzic
commit
0a0d289537
1 zmienionych plików z 2 dodań i 2 usunięć
  1. 2 2
      server.py

+ 2 - 2
server.py

@@ -314,7 +314,7 @@ def generate_reply(question, tokens, inference_settings, selected_model, eos_tok
         t0 = time.time()
         t0 = time.time()
         if args.deepspeed:
         if args.deepspeed:
             with torch.no_grad():
             with torch.no_grad():
-                output = eval(f"model.generate(input_ids, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset})")
+                output = eval(f"model.generate(input_ids, synced_gpus=True, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset})")
         else:
         else:
             output = eval(f"model.generate(input_ids, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset}){cuda}")
             output = eval(f"model.generate(input_ids, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset}){cuda}")
         reply = decode(output[0])
         reply = decode(output[0])
@@ -331,7 +331,7 @@ def generate_reply(question, tokens, inference_settings, selected_model, eos_tok
         for i in tqdm(range(tokens//8+1)):
         for i in tqdm(range(tokens//8+1)):
             if args.deepspeed:
             if args.deepspeed:
                 with torch.no_grad():
                 with torch.no_grad():
-                    output = eval(f"model.generate(input_ids, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset})")
+                    output = eval(f"model.generate(input_ids, synced_gpus=True, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset})")
             else:
             else:
                 output = eval(f"model.generate(input_ids, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset}){cuda}")
                 output = eval(f"model.generate(input_ids, eos_token_id={n}, stopping_criteria=stopping_criteria_list, {preset}){cuda}")
             reply = decode(output[0])
             reply = decode(output[0])