Get the current value atomically. Returns: The current integer value.

Get Slurm cluster information. This is useful for checking if the cluster is accessible and retrieving node information. Ret

Sends a PATCH request. A wrapper for the requests.patch method. Builds the url, uses custom headers, refresh tokens if needed.

Execute the task on the cluster. Returns: Job id if the task is submitted to the cluster, None otherwise.

Get a request from the queue. It is non-blocking if the queue is empty, and returns None. Returns: A tuple of request_id

Get information about the autoscaler.

Lazy sync engine init with double-checked locking.

Format the volume table for display.

* Get cached data or fetch fresh data * @param {Function} fetchFunction - The function to call to fetch data * @param {Array} [args=[]] - Argume

Gets a nested key. If any key is not found, or any intermediate key does not point to a dict value, returns 'default_value'.

Submit batch job as a managed job. Blocks until completion. The mapper function should be decorated with @sky.batch.remote_function a

Run the server process.

Create a copy of the context. Changes to the current context after this call will not affect the copy. The new context will get its o

Add a line to the buffer. Args: line: The log line to add Returns: True if buffer should be flushed after ad

Add a request to the request aggregator.

Plugin git commit hash.

Sets the required resources to execute this task. If this function is not called for a Task, default resource requirements will be us

Override to block until the generator naturally finishes. Default: does nothing — the caller drives termination via stop().

Launch the cluster for the first time. It can fail if resource is not available. Need to check the cluster status, after calling.

Sends a POST request. A wrapper for the requests.post method. Builds the url, uses custom headers, refresh tokens if needed.

This function is testing for the core functions on client side.

Deletes data for all sky-managed storage objects. If a storage is not managed by sky, it is not deleted from the cloud. User must man

Start the policy server in a background thread.

Returns a yaml-style dict representation of the task. INTERNAL: this method is internal-facing.

Initializes a task from a task YAML. Example: .. code-block:: python task = sky.Task.from_yaml('/path/to/task.ya

A workaround to make mypy understand that is_launchable() is true. Note: The `cast` to `LaunchableResources` is only for static type

Sends a GET request. A wrapper for the requests.get method. Builds the url, uses custom headers, refresh tokens if needed.

Submit a task for execution. If reuse_worker is False, wraps the function to exit after completion.

Helper to create a DebugDumpContext.

Detect the type of Kubernetes network based on node labels. Args: context: The Kubernetes context to check. network_t

Runs 'cmd' on the cluster's head node. It will try to fetch the head node IP if it is not cached. Args: handle: The Reso

Create a request if it does not exist. Returns: True if a new request was created, False if it already exists.

Load the GCP API for the instance type. Do not cache the resource object, as it will not work when multiple threads are running.

Clear current measurements.

Get existing allowed contexts that start with 'ssh-'. Override the Kubernetes implementation to only return contexts that start with

Helper to create a mock Request object.

Returns the cloud instance from the canonical name or alias.

Check if requested accelerator matches any viable name. For backward compatibility with GPU name changes (e.g., when canonical names like 'H2

Deserialize the SkyPilot API request.

* Invalidate a specific cache entry * @param {Function} fetchFunction - The function used to generate the cache key * @param {Array} [args=[]] -

Resolve the volume mount by populating metadata of volume.

Backs off once and returns the current backoff in seconds.

Check for volume mount conflicts and register the entry. Args: vol: Volume info to check. source: Where the volume ca

Returns a copy of the given Resources.

Get a request by ID with appropriate locking.

Helper to create a VolumeConfig with sensible defaults.

Run performance test for a single endpoint.