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, target_instances: int = 1, min_instances: int = 1, enable_metrics: bool = False, database: Optional[str] = None, schema: Optional[str] = None, 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

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

  • min_instances – The minimum number of nodes required to start the job. If none specified, defaults to 1. If set, the job will not start until the minimum number of nodes is available.

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

  • database – The database to use for the job.

  • schema – The schema to use 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.

Language: English