kernelfoundry.eval_pipeline.tasks.pull_image

Celery task for pulling container images on remote workers.

kernelfoundry.eval_pipeline.tasks.pull_image.pull_image(image_id: str, registry: str | None = None, allowed_container_registries: list[str] | None = None, timeout: int | None = None) dict

Pull a container image on the worker.

Celery task entry point. Pulls a container image by ID or name and returns metadata about the result.

Parameters:
  • image_id – The image ID or fully-qualified image name to pull.

  • registry – The container registry to use for pulling the image.

  • allowed_container_registries – List of allowed registries to pull from.

  • timeout – Maximum time in seconds to wait for the pull to complete.

Returns:

  • image_id: The pulled image ID (or None on failure)

  • hostname: Worker hostname where image was pulled

  • process_result: Encoded ProcessResult dict with return code and messages

Return type:

Dict with keys