mlflow.utils

class mlflow.utils.async_logging.run_operations.RunOperations(operation_futures)[源码]

用于管理 MLflow 异步日志记录的 futures 的类。

wait()[源码]

阻塞直到所有 futures 完成。

mlflow.utils.async_logging.run_operations.get_combined_run_operations(run_operations_list: list[mlflow.utils.async_logging.run_operations.RunOperations]) mlflow.utils.async_logging.run_operations.RunOperations[源码]

将 RunOperations 对象列表合并为一个 RunOperations 对象。

给定一个 RunOperations 列表,返回一个表示合并后的操作集的单个 RunOperations 对象。如果输入列表为空,则返回 None。如果输入列表只包含一个元素,则返回该元素。否则,创建一个新的 RunOperations 对象,该对象合并来自每个输入 RunOperations 对象的操作 futures。

参数

run_operations_list – 要合并的 RunOperations 对象列表。

返回

表示合并后的操作集的单个 RunOperations 对象。