Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Update ImageSpec documentation #5748

Open
wants to merge 3 commits into
base: master
Choose a base branch
from
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
188 changes: 153 additions & 35 deletions docs/user_guide/customizing_dependencies/imagespec.md
Original file line number Diff line number Diff line change
Expand Up @@ -6,68 +6,183 @@
.. tags:: Containerization, Intermediate
```

`ImageSpec` is a way to specify how to build a container image without a Dockerfile. The `ImageSpec` by default will be
converted to an [Envd](https://envd.tensorchord.ai/) config, and the [Envd builder](https://github.com/flyteorg/flytekit/blob/master/plugins/flytekit-envd/flytekitplugins/envd/image_builder.py#L12-L34) will build the image for you. However, you can also register your own builder to build
the image using other tools.
This guide demonstrates how to use the `ImageSpec` to customize the container image for your Flyte tasks.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
This guide demonstrates how to use the `ImageSpec` to customize the container image for your Flyte tasks.


`ImageSpec` is a mechanism that allows you to specify how to build a container image without requiring a Dockerfile.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
`ImageSpec` is a mechanism that allows you to specify how to build a container image without requiring a Dockerfile.
`ImageSpec` allows you to customize the container image for your Flyte tasks without a Dockerfile.

This feature provides a flexible and user-friendly way to define the containerization process.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
This feature provides a flexible and user-friendly way to define the containerization process.

One of the significant advantages of using ImageSpec is its ability to optimize the image-building process by reusing previously
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
One of the significant advantages of using ImageSpec is its ability to optimize the image-building process by reusing previously

downloaded packages from the PyPI and APT caches, thereby speeding up the entire build process.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
downloaded packages from the PyPI and APT caches, thereby speeding up the entire build process.
`ImageSpec` speeds up the build process by allowing you to reuse previously downloaded packages from the PyPI and APT caches.

This efficient caching mechanism minimizes redundant downloads, reducing both the time and resources required to construct the container image.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
This efficient caching mechanism minimizes redundant downloads, reducing both the time and resources required to construct the container image.


By default, the `ImageSpec` will be built using the `default` builder associated with Flytekit.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
By default, the `ImageSpec` will be built using the `default` builder associated with Flytekit.
By default, the `ImageSpec` will be built using the `default` builder associated with Flytekit, but you can register your own builder.

However, you have the option to register your own builder, enabling you to build the image using alternative tools.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
However, you have the option to register your own builder, enabling you to build the image using alternative tools.


For example, [flytekitplugins-envd](https://github.com/flyteorg/flytekit/blob/c06ef30518dec2057e554fbed375dfa43b985c60/plugins/flytekit-envd/flytekitplugins/envd/image_builder.py#L25) is another image builder that uses envd to build the ImageSpec.
This flexibility allows you to tailor the image-building process according to your specific needs and tool preferences.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
This flexibility allows you to tailor the image-building process according to your specific needs and tool preferences.


For every {py:class}`flytekit.PythonFunctionTask` task or a task decorated with the `@task` decorator,
you can specify rules for binding container images. By default, flytekit binds a single container image, i.e.,
the [default Docker image](https://ghcr.io/flyteorg/flytekit), to all tasks. To modify this behavior,
use the `container_image` parameter available in the {py:func}`flytekit.task` decorator, and pass an
`ImageSpec`.

Before building the image, Flytekit checks the container registry first to see if the image already exists. By doing so, it avoids having to rebuild the image over and over again. If the image does not exist, flytekit will build the image before registering the workflow, and replace the image name in the task template with the newly built image name.

```{note}
To clone and run the example code on this page, see the [Flytesnacks repo][flytesnacks].
```

```{rli} https://raw.githubusercontent.com/flyteorg/flytesnacks/69dbe4840031a85d79d9ded25f80397c6834752d/examples/customizing_dependencies/customizing_dependencies/image_spec.py
:caption: customizing_dependencies/image_spec.py
:lines: 1-4
```
Before building the image, Flytekit checks the container registry first to see if the image already exists.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
Before building the image, Flytekit checks the container registry first to see if the image already exists.
Before building the image, Flytekit checks the container registry to see if the image already exists.

By doing so, it avoids having to rebuild the image over and over again. If the image does not exist,
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
By doing so, it avoids having to rebuild the image over and over again. If the image does not exist,
If the image does not exist,

flytekit will build the image before registering the workflow, and replace the image name in the task template with the newly built image name.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
flytekit will build the image before registering the workflow, and replace the image name in the task template with the newly built image name.
Flytekit will build the image before registering the workflow and replace the image name in the task template with the newly built image name.


:::{admonition} Prerequisites
:class: important

- Install [flytekitplugins-envd](https://github.com/flyteorg/flytekit/tree/master/plugins/flytekit-envd) to build the `ImageSpec`.
- To build the image on remote machine, check this [doc](https://envd.tensorchord.ai/teams/context.html#start-remote-buildkitd-on-builder-machine).
- Make sure `docker` is running on your local machine.
- When using a registry in ImageSpec, `docker login` is required to push the image
:::

You can specify python packages, apt packages, and environment variables in the `ImageSpec`.
## Install Python or APT packages
You can specify python packages and apt packages in the `ImageSpec`.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
You can specify python packages and apt packages in the `ImageSpec`.
You can specify Python packages and APT packages in the `ImageSpec`.

These specified packages will be added on top of the [default image](https://github.com/flyteorg/flytekit/blob/master/Dockerfile), which can be found in the Flytekit Dockerfile.
More specifically, flytekit invokes [DefaultImages.default_image()](https://github.com/flyteorg/flytekit/blob/f2cfef0ec098d4ae8f042ab915b0b30d524092c6/flytekit/configuration/default_images.py#L26-L27) function.
This function determines and returns the default image based on the Python version and flytekit version. For example, if you are using python 3.8 and flytekit 0.16.0, the default image assigned will be `ghcr.io/flyteorg/flytekit:py3.8-1.6.0`.
If desired, you can also override the default image by providing a custom `base_image` parameter when using the `ImageSpec`.

```{rli} https://raw.githubusercontent.com/flyteorg/flytesnacks/69dbe4840031a85d79d9ded25f80397c6834752d/examples/customizing_dependencies/customizing_dependencies/image_spec.py
:caption: customizing_dependencies/image_spec.py
:lines: 6-19
```
This function determines and returns the default image based on the Python version and flytekit version.
For example, if you are using python 3.8 and flytekit 1.6.0, the default image assigned will be `ghcr.io/flyteorg/flytekit:py3.8-1.6.0`.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
For example, if you are using python 3.8 and flytekit 1.6.0, the default image assigned will be `ghcr.io/flyteorg/flytekit:py3.8-1.6.0`.
For example, if you are using Python 3.8 and flytekit 1.6.0, the default image assigned will be `ghcr.io/flyteorg/flytekit:py3.8-1.6.0`.


:::{important}
Replace `ghcr.io/flyteorg` with a container registry you can publish to.
To upload the image to the local registry in the demo cluster, indicate the registry as `localhost:30000`.
:::

`is_container` is used to determine whether the task is utilizing the image constructed from the `ImageSpec`.
If the task is indeed using the image built from the `ImageSpec`, it will then import Tensorflow.
```python
from flytekit import ImageSpec

sklearn_image_spec = ImageSpec(
packages=["scikit-learn", "tensorflow==2.5.0"],
apt_packages=["curl", "wget"],
registry="ghcr.io/flyteorg",
)
```

## Install Conda packages
Define the ImageSpec to install packages from a specific conda channel.
```python
image_spec = ImageSpec(
conda_packages=["langchain"],
conda_channels=["conda-forge"], # List of channels to pull packages from.
registry="ghcr.io/flyteorg",
)
```

## Use different Python versions in the image
You can specify the Python version in the `ImageSpec` to build the image with a different Python version.

```python
image_spec = ImageSpec(
packages=["pandas"],
python_version="3.9",
registry="ghcr.io/flyteorg",
)
```

## Import modules only in a specify imageSpec environment

`is_container()` is used to determine whether the task is utilizing the image constructed from the `ImageSpec`.
If the task is indeed using the image built from the `ImageSpec`, it will return true.
This approach helps minimize module loading time and prevents unnecessary dependency installation within a single image.

```{rli} https://raw.githubusercontent.com/flyteorg/flytesnacks/69dbe4840031a85d79d9ded25f80397c6834752d/examples/customizing_dependencies/customizing_dependencies/image_spec.py
:caption: customizing_dependencies/image_spec.py
:lines: 21-22
In the following example, both `task1` and `task2` will import the `pandas` module. However, `Tensorflow` will only be imported in `task2`.

```python
from flytekit import ImageSpec, task
import pandas as pd

pandas_image_spec = ImageSpec(
packages=["pandas"],
registry="ghcr.io/flyteorg",
)

tensorflow_image_spec = ImageSpec(
packages=["tensorflow", "pandas"],
registry="ghcr.io/flyteorg",
)

# Return if and only if the task is using the image built from tensorflow_image_spec.
if tensorflow_image_spec.is_container():
import tensorflow as tf

@task(container_image=pandas_image_spec)
def task1() -> pd.DataFrame:
return pd.DataFrame({"Name": ["Tom", "Joseph"], "Age": [1, 22]})


@task(container_image=tensorflow_image_spec)
def task2() -> int:
num_gpus = len(tf.config.list_physical_devices('GPU'))
print("Num GPUs Available: ", num_gpus)
return num_gpus
```

## Install CUDA in the image
There are few ways to install CUDA in the image.

### Use Nvidia docker image
CUDA is pre-installed in the Nvidia docker image. You can specify the base image in the `ImageSpec`.
```python
image_spec = ImageSpec(
base_image="nvidia/cuda:12.6.1-cudnn-devel-ubuntu22.04",
packages=["tensorflow", "pandas"],
python_version="3.9",
registry="ghcr.io/flyteorg",
)
```

To enable tasks to utilize the images built with `ImageSpec`, you can specify the `container_image` parameter for those tasks.
### Install packages from extra index
CUDA can be installed by specifying the `pip_extra_index_url` in the `ImageSpec`.
```python
image_spec = ImageSpec(
name="pytorch-mnist",
packages=["torch", "torchvision", "flytekitplugins-kfpytorch"],
pip_extra_index_url=["https://download.pytorch.org/whl/cu118"],
registry="ghcr.io/flyteorg",
)
```

## Build an image in different architecture
You can specify the platform in the `ImageSpec` to build the image in a different architecture, such as `linux/arm64` or `darwin/arm64`.
```python
image_spec = ImageSpec(
packages=["pandas"],
platform="linux/arm64",
registry="ghcr.io/flyteorg",
)
```

## Install flytekit from GitHub
When you update the flytekit, you may want to test the changes with your tasks.
You can install the flytekit from a specific commit hash in the `ImageSpec`.

```{rli} https://raw.githubusercontent.com/flyteorg/flytesnacks/69dbe4840031a85d79d9ded25f80397c6834752d/examples/customizing_dependencies/customizing_dependencies/image_spec.py
:caption: customizing_dependencies/image_spec.py
:lines: 27-56
```python
new_flytekit = "git+https://github.com/flyteorg/flytekit@90a4455c2cc2b3e171dfff69f605f47d48ea1ff1"
new_spark_plugins = f"git+https://github.com/flyteorg/flytekit.git@90a4455c2cc2b3e171dfff69f605f47d48ea1ff1#subdirectory=plugins/flytekit-spark"

image_spec = ImageSpec(
apt_packages=["git"],
packages=[new_flytekit, new_spark_plugins],
registry="ghcr.io/flyteorg",
)
```

## Customize the tag of the image
You can customize the tag of the image by specifying the `tag_format` in the `ImageSpec`.
In the following example, the full qualified image name will be `ghcr.io/flyteorg/my-image:<spec_hash>-dev`.

```python
image_spec = ImageSpec(
name="my-image",
packages=["pandas"],
tag_format="{spec_hash}-dev",
registry="ghcr.io/flyteorg",
)
```

There exists an option to override the container image by providing an Image Spec YAML file to the `pyflyte run` or `pyflyte register` command.
## Define ImageSpec in a YAML File
There is an option to override the container image by providing an ImageSpec YAML file to the `pyflyte run` or `pyflyte register` command.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
There is an option to override the container image by providing an ImageSpec YAML file to the `pyflyte run` or `pyflyte register` command.
You can override the container image by providing an ImageSpec YAML file to the `pyflyte run` or `pyflyte register` command.

This allows for greater flexibility in specifying a custom container image. For example:

```yaml
Expand All @@ -85,19 +200,22 @@ env:
pyflyte run --remote --image image.yaml image_spec.py wf
```

## Build the image without registering the workflow
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
## Build the image without registering the workflow
## Build the image without registering the workflow

If you only want to build the image without registering the workflow, you can use the `pyflyte build` command.

```
pyflyte build --remote image_spec.py wf
```

In some cases, you may want to force an image to rebuild, even if the image spec hasn’t changed. If you want to overwrite an existing image, you can pass the `FLYTE_FORCE_PUSH_IMAGE_SPEC=True` to `pyflyte` command or add `force_push()` to the ImageSpec.
## Force Push an Image
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
## Force Push an Image
## Force push an image

In some cases, you may want to force an image to rebuild, even if the image spec hasn’t changed.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
In some cases, you may want to force an image to rebuild, even if the image spec hasn’t changed.
In some cases, you may want to force an image to rebuild, even if the ImageSpec hasn’t changed.

If you want to overwrite an existing image, you can pass the `FLYTE_FORCE_PUSH_IMAGE_SPEC=True` to `pyflyte` command.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
If you want to overwrite an existing image, you can pass the `FLYTE_FORCE_PUSH_IMAGE_SPEC=True` to `pyflyte` command.
To overwrite an existing image, pass the `FLYTE_FORCE_PUSH_IMAGE_SPEC=True` to the `pyflyte` command.


```bash
FLYTE_FORCE_PUSH_IMAGE_SPEC=True pyflyte run --remote image_spec.py wf
```

or
You can also force push an image in the Python code by calling the `force_push()` method.

```python
image = ImageSpec(registry="ghcr.io/flyteorg", packages=["pandas"]).force_push()
Expand Down
Loading