snowflake.ml.jobs.MLJobDefinition¶

class snowflake.ml.jobs.MLJobDefinition(source: Union[str, Callable[[_Args], _ReturnValue]], compute_pool: str, stage_name: str, session: Optional[Session] = None, name: Optional[str] = None, target_instances: int = 1, min_instances: Optional[int] = None, generate_suffix: bool = True, external_access_integrations: Optional[list[str]] = None, env_vars: Optional[dict[str, str]] = None, spec_overrides: Optional[dict[str, Any]] = None, enable_metrics: bool = True, query_warehouse: Optional[str] = None, runtime_environment: Optional[str] = None, overwrite: bool = False, arg_protocol: ArgProtocol = ArgProtocol.NONE, default_args: Optional[list[Any]] = None, database: Optional[str] = None, schema: Optional[str] = None, payload: Optional[JobPayload] = None)¶

Bases: Generic[_Args, _ReturnValue], SerializableSessionMixin

Methods

delete() → None¶

classmethod register(source: Union[str, Callable[[_Args], _ReturnValue]], compute_pool: str, stage_name: str, session: Optional[Session] = None, **kwargs: Any) → MLJobDefinition[_Args, _ReturnValue]¶

Create and register a new MLJobDefinition instance eagerly.

This function or method is in private preview since 1.26.0.

to_sql(*, job_args: Optional[list[Any]] = None, use_async: bool = False) → str¶

Attributes

session¶