mlflow.utils

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

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

wait()[source]

阻塞,直到所有 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[source]

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

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

Parameters

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

Returns

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