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, 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

  • 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.

  • 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