mlflow.utils

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

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

wait()[源代码]

阻塞直到所有 future 完成。

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 对象的 **operation_futures**。

参数

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

返回

代表组合操作集的单个 RunOperations 对象。