ParallelTask Clase

Tarea paralela.

Herencia

azure.ai.ml.entities._mixins.RestTranslatableMixin

ParallelTask

azure.ai.ml.entities._mixins.DictMixin

ParallelTask

Constructor

ParallelTask(*, type: str | None = None, code: str | None = None, entry_script: str | None = None, program_arguments: str | None = None, model: str | None = None, append_row_to: str | None = None, environment: Environment | str | None = None, **kwargs: Any)

Parámetros

Nombre	Description
type Requerido	str Tipo de la tarea paralela. Los valores posibles son "run_function" y "model".
code Requerido	str Ruta de acceso local o remota que apunta al código fuente.
entry_script Requerido	str Script de usuario que se ejecutará en paralelo en varios nodos. Se especifica como una ruta de acceso del archivo local. entry_script debe contener dos funciones. init(): esta función debe usarse para cualquier preparación costosa o común para inferencias posteriores, por ejemplo, deserializar y cargar el modelo en un objeto global. run(mini_batch): método que se va a paralelizar. Cada invocación tendrá un minilote. "mini_batch": la inferencia por lotes invocará el método run y pasará una trama de datos de Pandas o una lista como argumento al método. Cada entrada de min_batch será una ruta de acceso si la entrada es FileDataset o una trama de datos de Pandas si es TabularDataset. El método run() debe devolver una trama de datos de Pandas o una matriz. Para append_row output_action, estos elementos devueltos se anexan al archivo de salida común. Para summary_only, se omite el contenido de los elementos. Para todas las acciones de salida, cada elemento de salida devuelto indica una inferencia correcta del elemento de entrada en el minilote de entrada. Cada proceso de trabajo paralelo llamará a init una vez y, a continuación, recorrerá en bucle la función de ejecución hasta que se procesen todos los minilotes.
program_arguments Requerido	str Argumentos de la tarea paralela.
model Requerido	str Modelo de la tarea paralela.
append_row_to Requerido	str Todas las invocaciones de método run() se agregarán a un archivo único que se crea en la ubicación de salida. Si no se establece, se invocaría "summary_only", lo que significa que se espera que el script de usuario almacene la salida en sí.
environment Requerido	Union[Environment, str] Entorno en el que se ejecutará el trabajo de entrenamiento.

Parámetros de solo palabra clave

Nombre	Description
type Requerido
code Requerido
entry_script Requerido
program_arguments Requerido
model Requerido
append_row_to Requerido
environment Requerido

Métodos

get
has_key
items
keys
update
values

get

get(key: Any, default: Any | None = None) -> Any

Parámetros

Nombre	Description
key Requerido
default	valor predeterminado: None

has_key

has_key(k: Any) -> bool

Parámetros

Nombre	Description
k Requerido

items

items() -> list

keys

keys() -> list

update

update(*args: Any, **kwargs: Any) -> None

values

values() -> list