Loading megatron/text_generation/api.py +6 −14 Original line number Diff line number Diff line Loading @@ -27,8 +27,6 @@ from .tokenization import ( tokenize_prompts, detokenize_generations) def generate_and_post_process(model, prompts=None, tokens_to_generate=0, Loading @@ -37,8 +35,7 @@ def generate_and_post_process(model, top_p_sampling=0.0, temperature=1.0, add_BOS=False, use_eod_token_for_early_termination=True, just_score=False): use_eod_token_for_early_termination=True): """Run inference and post-process outputs, i.e., detokenize, move to cpu and convert to list.""" Loading @@ -52,8 +49,7 @@ def generate_and_post_process(model, top_p_sampling=top_p_sampling, temperature=temperature, add_BOS=add_BOS, use_eod_token_for_early_termination=use_eod_token_for_early_termination, just_score=just_score) use_eod_token_for_early_termination=use_eod_token_for_early_termination) # Only post-process on first stage. if mpu.is_pipeline_first_stage(): Loading @@ -70,8 +66,6 @@ def generate_and_post_process(model, return None def generate(model, prompts=None, tokens_to_generate=0, Loading @@ -80,8 +74,7 @@ def generate(model, top_p_sampling=0.0, temperature=1.0, add_BOS=False, use_eod_token_for_early_termination=True, just_score=False): use_eod_token_for_early_termination=True): """Given prompts and input parameters, run inference and return: tokens: prompts plus the generated tokens. lengths: length of the prompt + generations. Note that we can Loading @@ -94,8 +87,8 @@ def generate(model, values = [tokens_to_generate, return_output_log_probs, top_k_sampling, top_p_sampling, temperature, add_BOS, use_eod_token_for_early_termination, just_score] values_float_tensor = broadcast_float_list(8, float_list=values) temperature, add_BOS, use_eod_token_for_early_termination] values_float_tensor = broadcast_float_list(7, float_list=values) tokens_to_generate = int(values_float_tensor[0].item()) return_output_log_probs = bool(values_float_tensor[1].item()) top_k_sampling = int(values_float_tensor[2].item()) Loading @@ -103,7 +96,6 @@ def generate(model, temperature = values_float_tensor[4].item() add_BOS = bool(values_float_tensor[5].item()) use_eod_token_for_early_termination = bool(values_float_tensor[6].item()) just_score = bool(values_float_tensor[7].item()) # Tokenize prompts and get the batch. # Note that these tensors are broadcaseted to all ranks. Loading @@ -113,7 +105,7 @@ def generate(model, context_tokens_tensor, context_length_tensor = tokenize_prompts( prompts=prompts, tokens_to_generate=tokens_to_generate, add_BOS=add_BOS) if just_score: if tokens_to_generate == 0: return score_and_return_on_first_stage( model, context_tokens_tensor, context_length_tensor) Loading megatron/text_generation_server.py +3 −7 Original line number Diff line number Diff line Loading @@ -54,15 +54,12 @@ class MegatronGenerate(Resource): return "Maximum number of prompts is 128", 400 tokens_to_generate = 64 # Choosing hopefully sane default. Full sequence is slow just_score=False if "tokens_to_generate" in request.get_json(): tokens_to_generate = request.get_json()["tokens_to_generate"] if not isinstance(tokens_to_generate, int): return "tokens_to_generate must be an integer greater than 0" if tokens_to_generate < 0: return "tokens_to_generate must be an integer greater than or equal to 0" if tokens_to_generate == 0: just_score = True logprobs = False if "logprobs" in request.get_json(): Loading @@ -70,8 +67,8 @@ class MegatronGenerate(Resource): if not isinstance(logprobs, bool): return "logprobs must be a boolean value" if just_score and not logprobs: return "tokens_to_generate=0 implies logprobs=True" if tokens_to_generate == 0 and not logprobs: return "tokens_to_generate=0 implies logprobs should be True" temperature = 1.0 if "temperature" in request.get_json(): Loading Loading @@ -117,8 +114,7 @@ class MegatronGenerate(Resource): top_p_sampling=top_p, temperature=temperature, add_BOS=add_BOS, use_eod_token_for_early_termination=True, just_score=just_score) use_eod_token_for_early_termination=True) return jsonify({"text": response, "segments": response_seg, Loading Loading
megatron/text_generation/api.py +6 −14 Original line number Diff line number Diff line Loading @@ -27,8 +27,6 @@ from .tokenization import ( tokenize_prompts, detokenize_generations) def generate_and_post_process(model, prompts=None, tokens_to_generate=0, Loading @@ -37,8 +35,7 @@ def generate_and_post_process(model, top_p_sampling=0.0, temperature=1.0, add_BOS=False, use_eod_token_for_early_termination=True, just_score=False): use_eod_token_for_early_termination=True): """Run inference and post-process outputs, i.e., detokenize, move to cpu and convert to list.""" Loading @@ -52,8 +49,7 @@ def generate_and_post_process(model, top_p_sampling=top_p_sampling, temperature=temperature, add_BOS=add_BOS, use_eod_token_for_early_termination=use_eod_token_for_early_termination, just_score=just_score) use_eod_token_for_early_termination=use_eod_token_for_early_termination) # Only post-process on first stage. if mpu.is_pipeline_first_stage(): Loading @@ -70,8 +66,6 @@ def generate_and_post_process(model, return None def generate(model, prompts=None, tokens_to_generate=0, Loading @@ -80,8 +74,7 @@ def generate(model, top_p_sampling=0.0, temperature=1.0, add_BOS=False, use_eod_token_for_early_termination=True, just_score=False): use_eod_token_for_early_termination=True): """Given prompts and input parameters, run inference and return: tokens: prompts plus the generated tokens. lengths: length of the prompt + generations. Note that we can Loading @@ -94,8 +87,8 @@ def generate(model, values = [tokens_to_generate, return_output_log_probs, top_k_sampling, top_p_sampling, temperature, add_BOS, use_eod_token_for_early_termination, just_score] values_float_tensor = broadcast_float_list(8, float_list=values) temperature, add_BOS, use_eod_token_for_early_termination] values_float_tensor = broadcast_float_list(7, float_list=values) tokens_to_generate = int(values_float_tensor[0].item()) return_output_log_probs = bool(values_float_tensor[1].item()) top_k_sampling = int(values_float_tensor[2].item()) Loading @@ -103,7 +96,6 @@ def generate(model, temperature = values_float_tensor[4].item() add_BOS = bool(values_float_tensor[5].item()) use_eod_token_for_early_termination = bool(values_float_tensor[6].item()) just_score = bool(values_float_tensor[7].item()) # Tokenize prompts and get the batch. # Note that these tensors are broadcaseted to all ranks. Loading @@ -113,7 +105,7 @@ def generate(model, context_tokens_tensor, context_length_tensor = tokenize_prompts( prompts=prompts, tokens_to_generate=tokens_to_generate, add_BOS=add_BOS) if just_score: if tokens_to_generate == 0: return score_and_return_on_first_stage( model, context_tokens_tensor, context_length_tensor) Loading
megatron/text_generation_server.py +3 −7 Original line number Diff line number Diff line Loading @@ -54,15 +54,12 @@ class MegatronGenerate(Resource): return "Maximum number of prompts is 128", 400 tokens_to_generate = 64 # Choosing hopefully sane default. Full sequence is slow just_score=False if "tokens_to_generate" in request.get_json(): tokens_to_generate = request.get_json()["tokens_to_generate"] if not isinstance(tokens_to_generate, int): return "tokens_to_generate must be an integer greater than 0" if tokens_to_generate < 0: return "tokens_to_generate must be an integer greater than or equal to 0" if tokens_to_generate == 0: just_score = True logprobs = False if "logprobs" in request.get_json(): Loading @@ -70,8 +67,8 @@ class MegatronGenerate(Resource): if not isinstance(logprobs, bool): return "logprobs must be a boolean value" if just_score and not logprobs: return "tokens_to_generate=0 implies logprobs=True" if tokens_to_generate == 0 and not logprobs: return "tokens_to_generate=0 implies logprobs should be True" temperature = 1.0 if "temperature" in request.get_json(): Loading Loading @@ -117,8 +114,7 @@ class MegatronGenerate(Resource): top_p_sampling=top_p, temperature=temperature, add_BOS=add_BOS, use_eod_token_for_early_termination=True, just_score=just_score) use_eod_token_for_early_termination=True) return jsonify({"text": response, "segments": response_seg, Loading