MCPcopy Create free account

hub / github.com/OpenDCAI/DataFlow-MM / functions

Functions991 in github.com/OpenDCAI/DataFlow-MM

Method_conversation_to_message
将格式1的数据转换为格式2。 支持多轮对话和多模态(图片、视频、音频),并验证token数量。
dataflow/io/qwen_audio/qwen_audio_2.py:63
Method_conversation_to_message
将格式1的数据转换为格式2。 支持多轮对话和多模态(图片、视频、音频),并验证token数量。
dataflow/io/unifiedreward_qwen/unifiedreward.py:64
Method_conversation_to_message
将格式1的数据转换为格式2。 支持多轮对话和多模态(图片、视频、音频),并验证token数量。
dataflow/io/qwen_vl/qwen_vl_2_5.py:106
Function_convert_image_to_rgb
(image)
dataflow/operators/core_vision/eval/image_text/model/longclip.py:31
Function_convert_weights_to_fp16
(l)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:491
Function_copy_scripts
()
dataflow/cli_funcs/cli_init.py:7
Function_custom_collate_fn
Custom collate function for DataLoader since we have variable-length image lists. We don't stack images; we just return lists.
dataflow/operators/core_vision/eval/video_ocr_evaluator.py:302
Function_exists
(v: Any)
dataflow/operators/core_vision/filter/video_info_filter.py:300
Function_fps_from_info
(v: Any)
dataflow/operators/core_vision/filter/video_scene_filter.py:446
Function_init_worker
(devices, model_init_args)
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:46
Function_init_worker
(devices, model_init_args)
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:19
Method_is_base64
check whether string is validate base64
dataflow/serving/api_vlm_serving_openai.py:328
Method_load_images_for_gemini
Load multiple image files, return PIL Image object list
dataflow/serving/api_image_gen_serving.py:382
Function_parallel_worker
子进程工作函数
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:54
Function_parallel_worker
子进程工作函数
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:330
Method_pass
(v: Optional[float])
dataflow/operators/core_vision/filter/video_luminance_filter.py:225
Method_pass
(v: Optional[float])
dataflow/operators/core_vision/filter/video_aesthetic_filter.py:220
Method_pass
(v: Optional[float])
dataflow/operators/core_vision/filter/video_ocr_filter.py:242
Function_path_from_cell
(v: Any)
dataflow/operators/core_vision/filter/video_scene_filter.py:438
Method_process_audio_chunk_static
静态方法封装,给多进程用
dataflow/operators/core_audio/generaterow/audio_timestamp_chunk_row_generator.py:230
Function_process_job
Top-level picklable worker for ProcessPoolExecutor.
dataflow/operators/core_vision/filter/video_scene_filter.py:46
Method_send_conversation_request_with_id
发送带有对话历史的单个请求 :param idx: 请求索引 :param conversation: 对话历史 :param image_paths: 图像路径列表 :param video_pat
dataflow/serving/api_vlm_serving_openai.py:830
Method_send_single_request_with_id
发送单个请求并返回结果 :param idx: 请求索引 :param prompt: 文本提示 :param image_paths: 图像路径列表 :param video_paths: 视频路径
dataflow/serving/api_vlm_serving_openai.py:619
Function_sort_key
(rec: Dict[str, Any])
dataflow/operators/core_vision/filter/video_info_filter.py:338
Function_worker
(task_queue, results_queue, task_params, process_id)
dataflow/operators/core_vision/generate/video_clip_generator.py:119
Methodanalyze_images_with_gpt_with_id
Batch-tracked version of `analyze_images_with_gpt`, returning (request_id, analysis). :param image_paths: List of image file paths.
dataflow/serving/api_vlm_serving_openai.py:417
Methodapi_chat
(self, system_info: str, messages: str, model: str)
dataflow/serving/api_llm_serving_request.py:50
Methodapi_chat_with_id
(system_info: str, messages: str, model: str, id)
dataflow/serving/api_llm_serving_request.py:80
Methodapply_wrapper
(row)
dataflow/operators/core_text/refine/functional_refiner.py:52
Methodbuild_full_prompts
输入: messages -> list of list (每个元素是聊天序列) 输出: full_prompts -> list of dict {prompt, multi_modal_data}
dataflow/io/qwen_audio/qwen_audio_2.py:32
Methodbuild_full_prompts
输入: messages -> list of list (每个元素是聊天序列) 输出: full_prompts -> list of dict {prompt, multi_modal_data}
dataflow/io/unifiedreward_qwen/unifiedreward.py:28
Methodbuild_full_prompts
输入: messages -> list of list (每个元素是聊天序列) 输出: full_prompts -> list of dict {prompt, multi_modal_data}
dataflow/io/qwen_vl/qwen_vl_2_5.py:27
Methodbuild_message
( self, user_inputs: list[list[dict]], image_list: list[list[str]] = None, vid
dataflow/io/qwen_vl/qwen_vl_2_5.py:63
Methodbuild_prompt
参数: - need_fields: 本次会使用到的字段名集合(来自算子的 input_keys.keys()) - kwargs: 每个字段名 -> 该行的值(来自 DataFrame) 逻辑: - 对于每个字段名
dataflow/prompts/prompt_template.py:33
Methodbuild_prompt
(self)
dataflow/prompts/image.py:11
Methodbuild_prompt
(self)
dataflow/prompts/image.py:25
Methodbuild_prompt
(self)
dataflow/prompts/image.py:79
Methodbuild_prompt
(self)
dataflow/prompts/image.py:96
Methodbuild_prompt
(self)
dataflow/prompts/image.py:132
Methodbuild_prompt
(self)
dataflow/prompts/image.py:176
Methodbuild_prompt
Generate system prompt for video quality evaluation.
dataflow/prompts/video.py:15
Methodbuild_prompt
(self, caption: str)
dataflow/prompts/video.py:29
Methodbuild_prompt
Generate prompt for CoT QA generation with question parameter.
dataflow/prompts/video.py:71
Methodbuild_prompt
(self, data)
dataflow/prompts/prompt_generator.py:6
Methodchat_with_one_image_with_id
Same as `chat_with_one_image` but returns a tuple of (request_id, response). :param request_id: Arbitrary identifier for tracking th
dataflow/serving/api_vlm_serving_openai.py:256
Methodchntext2cardinal
(self)
dataflow/operators/core_audio/refine/cn_tn.py:757
Methodchntext2fraction
(self)
dataflow/operators/core_audio/refine/cn_tn.py:822
Methodchntext2percentage
(self)
dataflow/operators/core_audio/refine/cn_tn.py:921
Methodcleanup
Cleanup the generator and garbage collect all GPU/CPU memory.
dataflow/core/LLMServing.py:16
Methodcleanup
(self)
dataflow/serving/local_model_llm_serving.py:123
Methodcleanup
(self)
dataflow/serving/local_model_llm_serving.py:310
Methodcleanup
(self)
dataflow/serving/api_llm_serving_request.py:174
Methodcleanup
Clean up any resources (e.g., close HTTP connections).
dataflow/serving/api_vlm_serving_openai.py:496
Methodcleanup
Clear pipelines and free GPU memory.
dataflow/serving/local_image_gen_serving.py:248
Methodcleanup
Cleanup resources.
dataflow/serving/lite_llm_serving.py:396
Methodcleanup
(self)
dataflow/serving/local_model_vlm_serving.py:213
Methodcleanup
(self)
dataflow/serving/local_model_vlm_serving.py:447
Methodcleanup
(self)
dataflow/serving/api_image_gen_serving.py:749
Methodclose
(self)
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:350
Methodclose
(self)
dataflow/operators/core_audio/filter/audio_ctc_forced_alignment_transcription_quality_filter.py:230
Methodclose
(self)
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:325
Methodcompute_bleu_score
Calculate BLEU score.
dataflow/operators/core_vision/eval/general_text_answer_evaluator.py:84
Functioncompute_correlation_uniquehuman
(pred, all_human_scores)
dataflow/utils/utils.py:52
Methodconvert_chinese_to_pinyin
(text: str)
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:257
Functioncopy_file
Copy a single file with path, with checking and asking about the existence.
dataflow/cli_funcs/copy_funcs.py:5
Functioncopy_files_without_recursion
Copy files under a path without recursion, with checking and asking about the existence.
dataflow/cli_funcs/copy_funcs.py:23
Methodcreate
(cls, i, v)
dataflow/operators/core_audio/refine/cn_tn.py:457
Methodcurrent_timestep
(self)
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:716
Methoddeco
(func_or_class)
dataflow/utils/registry.py:96
Methoddisable_vae_slicing
r""" Disable sliced VAE decoding. If `enable_vae_slicing` was previously enabled, this method will go back to computing decoding in on
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:617
Methoddisable_vae_tiling
r""" Disable tiled VAE decoding. If `enable_vae_tiling` was previously enabled, this method will go back to computing decoding in one
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:634
Methoddtype
(self)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:350
Methodduration_sec
(self)
dataflow/operators/core_vision/filter/video_scene_filter.py:102
Functionem_cos_score
Compute EMScore. Args: - :param: `model` : a BERT model in `pytorch_pretrained_bert` - :param: `refs` (list of str): referen
dataflow/utils/utils.py:265
Methodembed_with_retry
(text: str, retry_times: int = 3)
dataflow/serving/lite_llm_serving.py:349
Methodenable_vae_slicing
r""" Enable sliced VAE decoding. When this option is enabled, the VAE will split the input tensor in slices to compute decoding in sev
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:609
Methodenable_vae_tiling
r""" Enable tiled VAE decoding. When this option is enabled, the VAE will split the input tensor into tiles to compute decoding and en
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:625
Methodencode_text_full
(self, text)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:372
Functionextract_clean_cot_logic
[For FunctionalRefiner] 仅返回清洗后的 CoT 文本
dataflow/statics/pipelines/gpu_pipelines/image_gcot_pipeline.py:44
Functionextract_clean_cot_logic
[For FunctionalRefiner] 仅返回清洗后的 CoT 文本
dataflow/statics/pipelines/api_pipelines/image_gcot_api_pipeline.py:47
Functionextract_keywords_logic
[For FunctionalRefiner] 提取并合并关键词
dataflow/statics/pipelines/gpu_pipelines/image_gcot_pipeline.py:48
Functionextract_keywords_logic
[For FunctionalRefiner] 提取并合并关键词
dataflow/statics/pipelines/api_pipelines/image_gcot_api_pipeline.py:51
Methodforward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:93
Methodforward
Args: images_bnc: (B, N, C, H, W) preprocessed images Returns: scores: (B,) averaged aesthetic score per clip
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:125
Methodforward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:42
Methodforward
(self, x)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:68
Methodforward
(self, x)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:138
Methodforward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:160
Methodforward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:167
Methodforward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:189
Methodforward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:202
Methodforward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:223
Methodgenerate_derivative_question
(self, fn: "MultimodalMathGenerator.MathFunction")
dataflow/operators/core_vision/generate/multimodal_math_generator.py:169
Methodgenerate_embedding_from_input
(self, texts: list[str])
dataflow/serving/local_model_llm_serving.py:119
Methodgenerate_embedding_from_input
Generate embeddings for a list of texts. Args: texts: List of text strings to embed Returns
dataflow/serving/lite_llm_serving.py:319
Methodgenerate_extremum_question
(self, fn: "MultimodalMathGenerator.MathFunction")
dataflow/operators/core_vision/generate/multimodal_math_generator.py:179
Methodgenerate_from_conversations
(self, conversations: list[list[dict]])
dataflow/serving/api_llm_serving_request.py:128
Methodgenerate_from_input
(self, *args, **kwargs)
test/test_data_selection.py:36
Methodgenerate_from_input
(self, user_inputs: list[str], system_prompt: str =
dataflow/serving/local_model_llm_serving.py:99
Methodgenerate_from_input
(self, user_inputs: list[str], system_prompt: str = "
dataflow/serving/local_model_llm_serving.py:285
← previousnext →701–800 of 991, ranked by callers