Aidan/dind+bugfix

CHANGELOG.md

@@ -18,6 +18,18 @@ Types of changes
 
 ### Fixed
 
+* Create latch config file if it does not exist at registration or develop time
+
+### Added
+
+* `latch init`: Docker in Docker template workflow
+* `latch init`: Docker base image
+* Small, medium, and large tasks run with sysbox runtime allowing the execution system-level software such as systemd, Docker, Kubernetes, K3s, buildx, legacy apps, and more.
+
+## 2.13.1 - 2023-02-17
+
+### Fixed
+
 * Add latch/latch_cli/services/init/common to pypi release
 
 ## 2.13.0 - 2023-02-17

docs/source/api/latch_cli.rst

@@ -57,18 +57,18 @@ latch\_cli.tui module
    :undoc-members:
    :show-inheritance:
 
-latch\_cli.types module
+latch\_cli.utils module
 -----------------------
 
-.. automodule:: latch_cli.types
+.. automodule:: latch_cli.utils
    :members:
    :undoc-members:
    :show-inheritance:
 
-latch\_cli.utils module
------------------------
+latch\_cli.workflow\_config module
+----------------------------------
 
-.. automodule:: latch_cli.utils
+.. automodule:: latch_cli.workflow_config
    :members:
    :undoc-members:
    :show-inheritance:

docs/source/basics/defining_environment.md

@@ -4,7 +4,7 @@ Workflow code is rarely free of dependencies. It may require python or system pa
 
 Latch manages the execution environment of a workflow using Dockerfiles. A Dockerfile specifies the environment in which the workflow runs.
 
-Latch has three [base images](https://docs.docker.com/build/building/base-images/), one without hardware acceleration drivers, one with CUDA drivers, and one with OPENCL drivers. To use the CUDA or OPENCL base image, use the `--cuda` or `--opencl` flags when running `latch init`.
+Latch has four [base images](https://docs.docker.com/build/building/base-images/), one bare minimum, one with CUDA drivers, one with OPENCL drivers, and one with Docker pre-installed. To use the CUDA, OPENCL, or Docker base image, provide the specific value using the `--base-image` option when running `latch init`.
 
 The workflow environment is encapsulated in [a Docker container](https://en.wikipedia.org/wiki/Docker_(software)), which is created from a recipe defined in [a text document called Dockerfile.](https://docs.docker.com/engine/reference/builder/) In most cases these recipes are repetitive and unnecessarily complicated, so Latch will automatically generate one using conventional dependency lists and heuristics. To use a handwritten Dockerfile, [run the eject command](#ejecting-auto-generation).
 
@@ -260,7 +260,7 @@ The default `.dockerignore` includes files auto-generated by Latch.
 
 ## Docker Limitations
 
-Docker containers have limitations on some system administration functions. While each workflow runs as a genuine `root` user (UID 0), commands that require [kernel capabilities](https://man7.org/linux/man-pages/man7/capabilities.7.html) will fail with "Permission denied". This includes `mount` and `chroot` among others.
+Docker containers have limitations on some system administration functions. While each workflow runs as a genuine `root` user (UID 0), commands that require certain [kernel capabilities](https://man7.org/linux/man-pages/man7/capabilities.7.html) will fail with "Permission denied". This includes `chown` and `chroot` among others. However, for non-GPU tasks, we use a [container runtime](https://github.com/nestybox/sysbox) that gets around this issue. For example, a user can run a Docker container inside a `small_task` (Docker in Docker), which is disallowed using the normal Docker runtime. 
 
 ---
 

docs/source/basics/environment/docker_recipes.md

@@ -9,3 +9,7 @@ RUN curl -L https://sourceforge.net/projects/bowtie-bio/files/bowtie2/2.4.4/bowt
     unzip bowtie2-2.4.4.zip &&\
     mv bowtie2-2.4.4-linux-x86_64 bowtie2
 ```
+
+## Run Docker in Docker
+
+Latch provides a base image which includes Docker. Specify the `--base-image docker` argument to `latch init` to use the image. Latch provides a comprehensive example of running a containerized `bowtie2` aligner in a Latch workflow, which can be found by running `latch init --template docker ...`.

docs/source/subcommands.md

@@ -20,13 +20,9 @@ One of `r`, `conda`, `subprocess`, `empty`. If not provided, user will be prompt
 
 Generate a Dockerfile for the workflow instead of relying on [auto-generation.](basics/defining_environment.md#automatic-dockerfile-generation)
 
-#### `--cuda`
+#### `--base-image`, `-b`
 
-Make cuda drivers available to task code.
-
-#### `--opencl`
-
-Make opencl drivers available to task code.
+One of `opencl`, `cuda`, `docker`, `default`. If provided, the workflow will be built using with the specified software in the environment. These options are mutually exclusive. If not provided or `default`, will use a bare-minimum image.
 
 ## `latch register`
 

latch/resources/tasks.py

@@ -87,7 +87,9 @@ def _get_large_pod() -> Pod:
     primary_container.resources = resources
 
     return Pod(
+        annotations={"io.kubernetes.cri-o.userns-mode": "auto:size=65536"},
         pod_spec=V1PodSpec(
+            runtime_class_name="sysbox-runc",
             containers=[primary_container],
             tolerations=[
                 V1Toleration(effect="NoSchedule", key="ng", value="cpu-96-spot")
@@ -108,7 +110,9 @@ def _get_medium_pod() -> Pod:
     primary_container.resources = resources
 
     return Pod(
+        annotations={"io.kubernetes.cri-o.userns-mode": "auto:size=65536"},
         pod_spec=V1PodSpec(
+            runtime_class_name="sysbox-runc",
             containers=[primary_container],
             tolerations=[
                 V1Toleration(effect="NoSchedule", key="ng", value="cpu-32-spot")
@@ -129,7 +133,9 @@ def _get_small_pod() -> Pod:
     primary_container.resources = resources
 
     return Pod(
+        annotations={"io.kubernetes.cri-o.userns-mode": "auto:size=65536"},
         pod_spec=V1PodSpec(
+            runtime_class_name="sysbox-runc",
             containers=[primary_container],
         ),
         primary_container_name="primary",
@@ -289,14 +295,18 @@ def custom_task(cpu: int, memory: int):
     primary_container.resources = resources
     if cpu < 48 and memory < 128:
         task_config = Pod(
+            annotations={"io.kubernetes.cri-o.userns-mode": "auto:size=65536"},
             pod_spec=V1PodSpec(
+                runtime_class_name="sysbox-runc",
                 containers=[primary_container],
             ),
             primary_container_name="primary",
         )
     elif cpu < 96 and memory < 180:
         task_config = Pod(
+            annotations={"io.kubernetes.cri-o.userns-mode": "auto:size=65536"},
             pod_spec=V1PodSpec(
+                runtime_class_name="sysbox-runc",
                 containers=[primary_container],
                 tolerations=[
                     V1Toleration(effect="NoSchedule", key="ng", value="cpu-96-spot")

latch/types/directory.py

@@ -148,7 +148,6 @@ def to_python_value(
                 "Casting from Pathlike to LatchDir is currently not supported."
             )
 
-
         while get_origin(expected_python_type) == Annotated:
             expected_python_type = get_args(expected_python_type)[0]
 

latch_cli/constants.py

@@ -7,7 +7,7 @@
 @dataclass(frozen=True)
 class LatchConstants:
     base_image: str = (
-        "812206152185.dkr.ecr.us-west-2.amazonaws.com/latch-base:ace9-main"
+        "812206152185.dkr.ecr.us-west-2.amazonaws.com/latch-base:9c8f-main"
     )
 
     mib: int = 2**20

latch_cli/docker_utils/__init__.py

@@ -6,10 +6,11 @@
 from textwrap import dedent
 from typing import List
 
+import click
 import yaml
 
 from latch_cli.constants import latch_constants
-from latch_cli.types import LatchWorkflowConfig
+from latch_cli.workflow_config import LatchWorkflowConfig, create_and_write_config
 
 
 class DockerCmdBlockOrder(str, Enum):
@@ -202,9 +203,12 @@ def generate_dockerfile(pkg_root: Path, outfile: Path) -> None:
             print("  - base image:", config.base_image)
             print("  - latch version:", config.latch_version)
     except FileNotFoundError as e:
-        raise RuntimeError(
-            "Could not find a .latch/config file in the supplied directory. If your workflow was created prior to release 2.13.0, you may need to run `latch init` to generate a .latch/config file."
-        ) from e
+        print(
+            "Could not find a .latch/config file in the supplied directory. Creating configuration."
+        )
+        create_and_write_config(pkg_root)
+        with open(pkg_root / latch_constants.pkg_config) as f:
+            config: LatchWorkflowConfig = LatchWorkflowConfig(**json.load(f))
 
     with outfile.open("w") as f:
         f.write("\n".join(get_prologue(config)) + "\n\n")

latch_cli/main.py

@@ -10,7 +10,7 @@
 
 import latch_cli.click_utils
 from latch_cli.exceptions.handler import CrashHandler
-from latch_cli.services.init.init import template_flag_to_option
+from latch_cli.services.init.init import BaseImageOptions, template_flag_to_option
 from latch_cli.utils import get_latest_package_version, get_local_package_version
 
 latch_cli.click_utils.patch()
@@ -161,23 +161,20 @@ def login(connection: Optional[str]):
     default=False,
 )
 @click.option(
-    "--cuda",
-    help="Create a user editable Dockerfile for this workflow.",
-    is_flag=True,
-    default=False,
-)
-@click.option(
-    "--opencl",
-    help="Create a user editable Dockerfile for this workflow.",
-    is_flag=True,
-    default=False,
+    "--base-image",
+    "-b",
+    help="Which base image to use for the Dockerfile.",
+    type=click.Choice(
+        list(BaseImageOptions._member_names_),
+        case_sensitive=False,
+    ),
+    default="default",
 )
 def init(
     pkg_name: str,
     template: Optional[str] = None,
     dockerfile: bool = False,
-    cuda: bool = False,
-    opencl: bool = False,
+    base_image: str = "default",
 ):
     """Initialize boilerplate for local workflow code."""
 
@@ -186,7 +183,7 @@ def init(
 
     from latch_cli.services.init import init
 
-    created = init(pkg_name, template, dockerfile, cuda, opencl)
+    created = init(pkg_name, template, dockerfile, base_image)
     if created:
         click.secho(f"Created a latch workflow in `{pkg_name}`", fg="green")
         click.secho("Run", fg="green")

latch_cli/services/init/example_docker/assemble.py

@@ -0,0 +1,65 @@
+import subprocess
+from pathlib import Path
+
+from latch import small_task
+from latch.functions.messages import message
+from latch.types import LatchFile, LatchOutputDir
+
+
+@small_task
+def assembly_task(
+    read1: LatchFile, read2: LatchFile, output_directory: LatchOutputDir
+) -> LatchFile:
+
+    outdir = Path("/root/outputs").resolve()
+    outdir.mkdir(exist_ok=True)
+
+    bowtie2_cmd = [
+        "docker",
+        "run",
+        "--user",
+        "root",
+        "--env",
+        "BOWTIE2_INDEXES=/reference",
+        "--mount",
+        "type=bind,source=/root/reference,target=/reference",
+        "--mount",
+        f"type=bind,source={read1.local_path},target=/r1.fq",
+        "--mount",
+        f"type=bind,source={read2.local_path},target=/r2.fq",
+        "--mount",
+        f"type=bind,source={outdir},target=/outputs",
+        "biocontainers/bowtie2:v2.4.1_cv1",
+        "bowtie2",
+        "--local",
+        "--very-sensitive-local",
+        "-x",
+        "wuhan",
+        "-1",
+        "/r1.fq",
+        "-2",
+        "/r2.fq",
+        "-S",
+        "/outputs/covid_assembly.sam",
+    ]
+
+    try:
+        # We use shell=True for all the benefits of pipes and other shell features.
+        # When using shell=True, we pass the entire command as a single string as
+        # opposed to a list since the shell will parse the string into a list
+        # using its own rules.
+        subprocess.run(" ".join(bowtie2_cmd), shell=True, check=True)
+    except subprocess.CalledProcessError as e:
+        # will display in the messages tab of the execution graph for the assembly_task node
+        message(
+            "error",
+            {"title": "Bowtie2 Failed", "body": f"Error: {str(e)}"},
+        )
+        raise e
+
+    # intended output path of the file in Latch console, constructed from
+    # the user provided output directory
+    output_location = f"{output_directory.remote_directory}/covid_assembly.sam"
+    local_sam_file = outdir / "covid_assembly.sam"
+
+    return LatchFile(str(local_sam_file), output_location)