Run Containerized Talend Studio jobs

Using the KubernetesPodOperator to execute Talend jobs. The Talend jobs are containerized, saved to a registry, and then orchestrated from Airflow.




Last Updated: Aug. 26, 2021

Run this DAG

1. Install the Astronomer CLI:Skip if you already have our CLI

2. Download the repository:

3. Navigate to where the repository was cloned and start the DAG:


This repo contains an Astronomer project with two example DAGs showing how to use Airflow to execute Talend jobs. A guide discussing the DAGs and concepts in depth can be found here.

Tutorial Overview

There are a few main ways to execute Talend jobs with Airflow:

  • Containerize Talend Studio jobs and execute them using the KubernetesPodOperator
  • Execute Talend Cloud jobs using the Talend API and the SimpleHttpsOperator

This tutorial has one DAG to illustrate each method.


In addition to the Astronomer CLI, to follow this tutorial you will need the following:

  • A Talend Cloud account
  • Talend Studio installed locally
  • Docker installed locally
  • A Dockerhub account, or other Docker registry

Getting Started

The easiest way to run these example DAGs is to use the Astronomer CLI to get an Airflow instance up and running locally:

  1. Install the Astronomer CLI
  2. Clone this repo somewhere locally and navigate to it in your terminal
  3. Initialize an Astronomer project by running astro dev init
  4. Start Airflow locally by running astro dev start
  5. Navigate to localhost:8080 in your browser and you should see the tutorial DAGs there

Refer to the detailed guide linked above for instructions on how to get Airflow set up specifically for these DAGs.