snowflake.ml.jobs.remote¶

snowflake.ml.jobs.remote(compute_pool: str, *, stage_name: str, pip_requirements: Optional[List[str]] = None, external_access_integrations: Optional[List[str]] = None, query_warehouse: Optional[str] = None, env_vars: Optional[Dict[str, str]] = None, num_instances: Optional[int] = None, enable_metrics: bool = False, session: Optional[Session] = None) → Callable[[Callable[[_Args], _ReturnValue]], Callable[[_Args], MLJob[_ReturnValue]]]¶

Submit a job to the compute pool.

Parameters:

• compute_pool – The compute pool to use for the job.

• stage_name – The name of the stage where the job payload will be uploaded.

• pip_requirements – A list of pip requirements for the job.

• external_access_integrations – A list of external access integrations.

• query_warehouse – The query warehouse to use. Defaults to session warehouse.

• env_vars – Environment variables to set in container

• num_instances – The number of nodes in the job. If none specified, create a single node job.

• enable_metrics – Whether to enable metrics publishing for the job.

• session – The Snowpark session to use. If none specified, uses active session.

Returns:

Decorator that dispatches invocations of the decorated function as remote jobs.

This function or method is in private preview since 1.7.4.