Skip to Content
Technical Articles
Author's profile photo Karim Mohraz

Train your model in SAP AI Core using the Metaflow-Argo plugin

Metaflow helps data-scientists and developers to create scalable Machine Learning services and bring them to production faster. For a good overview on how to build and productize ML services with Metaflow see:

The Metaflow Python library for SAP AI Core extends Metaflow’s capabilities to run ML training pipelines as Argo Workflows.

In this blog you will learn how to leverage the Metaflow-Argo plugin for generating training templates for SAP AI Core:

  • You can experiment with local data right in your python environment and adjust your ML code iteratively.
  • Once ready for running the training pipeline on Kubernetes, generate the Argo template directly from your ML code.
  • Even the iterations for fine tuning the pipeline for SAP AI Core are supported by the Metaflow-Argo plugin, which makes productization easier and more fun!


  1. Prerequisites
  2. Install the Metaflow-Argo plugin
  3. Define the Training pipeline
  4. Run the Training pipeline in SAP AI Core


You should be familiar with the following components of SAP AI Core:

  1. SAP Business Technology Platform (SAP BTP) account
  2. Docker
  3. Kubernetes (K8s)
  4. Argo Workflows
  5. AI-API

You have provisioned SAP AI Core for your SAP BTP account and configured the:

  1. Object Storage
  2. Docker registry
  3. Git repo

Install and configure Metaflow

  1. Install the sap-ai-core-metaflow package from the PyPi repository:
    pip install sap-ai-core-metaflow
  2. Configure Metaflow
    For running the same code locally and on the K8s cluster, Metaflow stores code packages into the S3 bucket.
    Create the following config file on your computer: ~/.metaflowconfig/config.json and fill in the bucket name registered for your SAP AI Core account:

        "METAFLOW_DATASTORE_SYSROOT_S3": "s3://<my-bucket>/metaflow",
        "METAFLOW_DATATOOLS_SYSROOT_S3": "s3://<my-bucket>/metaflow/data",
  3. Configure credentials for the S3 bucket
    Create the file ~/.aws/credentials and add the content below:

    aws_access_key_id = xxxx
    aws_secret_access_key = yyyy

Define the Training pipeline

Here is an example for a multi-step pipeline, where you can add your own training code to the individual steps (see @step decorators):

  • Each step will be run
    • locally in a cpu thread or
    • on K8s in a separate pod.
  • You can assign a separate docker image for each step (see @kubernetes decorator).
from metaflow import FlowSpec, step, kubernetes

class TrainFlow(FlowSpec):

    # @kubernetes(image="<docker-repo>/<metaflow-data:tag>")
    def start(self):
        print('Load data / Preprocessing')

    # @kubernetes(image="<docker-repo>/<metaflow-train:tag>")
    def train_model(self):
        print('Train a model')

    # @kubernetes(image="<docker-repo>/<metaflow-evaluate:tag>")
    def end(self):
        print('Evaluation / Metrics')

if __name__ == '__main__':

Save this metaflow script into a file with the name “”.

Develop and test your flow locally, before running it on SAP AI Core’s K8s cluster:

python run

Learn more about the Metaflow features in these great tutorials.

Run the Training pipeline in SAP AI Core

The engine for running training pipelines in SAP AI Core is Argo Workflows.

The Metaflow-Argo plugin relieves the user from mastering the Argo workflow syntax to write such a workflow in yaml / json. The next sections describe how the workflow template can be generated from the above python ML code.

Docker Images

The docker images for each step of the training pipeline have to be built and pushed to the docker registry prior to starting the workflow. However, Metaflow makes the life of the data-scientist a lot easier:

  • When creating the Argo workflow, behind the scenes metaflow copies your metaflow script ( to S3.
  • When the Argo Workflow is started in K8s, a piece of code added to the template copies your  metaflow script from S3 to the docker container. Thus it runs the same ML code as your local version!

Here is an example Dockerfile, which installs the Metaflow-Argo plugin and awscli for copying the code packages that allow your metaflow script to run in the container:

# Generates a docker image to run Metaflow flows in SAP AI Core

FROM python:3.8-slim

# Install metaflow library (updates your latest metaflow script during runtime)
RUN pip install sap-ai-core-metaflow awscli && \
    pip install <additional libraries>

#   SAP AI Core executes containers only in root-less mode!
RUN mkdir -m 777 /home/user

WORKDIR /home/user
ENV HOME=/home/user

In the “pip install” section you can add additional libraries required for your ML code.

Build the docker images using above Dockerfile and push to your docker registry:

docker build -t <docker-registry>/<metaflow-xyz:tag> -f Dockerfile .

docker push <docker-registry>/<metaflow-xyz:tag>


Generate the Training Template

The training template can be generated using command-line options. To list all options which are supported by the Argo plugin, use the --help option:

python argo --help

Argo Workflows accepts both YAML and JSON templates. (The plugin always creates JSON.)
With the option --only-json the resulting template is printed out and can be saved to a file.

When finished with local runs, uncomment the @kubernetes decorators for each step. The full command including all parameters required for generating the template is:

python --with=kubernetes:secrets=default-object-store-secret argo create --image-pull-secret=<AI Core docker secret> --label={"":"<Ml-Scenario>","":"1.0.0"} --annotation={"":"<ML-Scenario-Name>","":"trainflow"} --only-json > trainflow.json

The SAP AI Core parameters are explained below:

Labels and Annotations

An SAP AI Core training template is a standard Argo workflow template + a set of labels and annotations processed by SAP AI Core.

These labels / annotations are mandatory:


Note: the class name that you use in the ML code (e.g. TrainFlow”) is used as the executable ID after being converted to lowercase (see template tag: metadata→name). Use exactly the same name also for the annotation

SAP AI Core Secrets

Pulling the docker images and accessing the object-storage (S3) requires credentials. These are referenced as secrets in the SAP AI Core template:

  • image-pull-secret
  • default-object-store-secret

Execute the Workflow in SAP AI Core

Push the resulting training template trainflow.json into the registered git repository. The template can then be executed via AI-API.

For SAP AI Core tutorials check out SAP Tutorials for Developers.


This blog post demonstrates how a Data Scientist can easily run the same ML code both locally and on a K8s cluster. This allows to keep the effort low when moving the code from experimentation to production on SAP AI Core. Debugging in a production environment is impaired by many restrictions, therefor it is important to iron out possible errors before pushing the code to production.

I want to thank Elham Zamnansani and Roman Kindruk (co-developers of the Metaflow-Argo plugin) for their support in writing this post.

Please add your thoughts on this post in the Comments section below.

Assigned Tags

      1 Comment
      You must be Logged on to comment or reply to a post.
      Author's profile photo Karim Mohraz
      Karim Mohraz
      Blog Post Author

      Our contribution finally made it to the open-source version of Metaflow:

      So now you can create ML Argo workflows for SAP AI core (using our plugin) and for standard K8s.