talend-task 0.1.9

CLI and Python API for running Talend Cloud jobs

talend-task

CLI and Python API for running Talend Cloud jobs

• Copyright (c) 2026 Corey Goldberg
• Development: GitHub
• Releases: PyPI
• License: MIT

---

Status

Latest Version
Build (CI)
Supported Python Versions

---

About

The talend-task package provides a command-line interface and Python API client for executing and monitoring jobs in Talend Cloud, including ETL pipelines and other data workflows. It uses the Processing API to trigger executions and monitor their status.

The package consists of:

• command-line interface (talend_task)
• Python API client module (talend_task.talend_client) providing the TalendClient class
  • API documentation

In this package, a “job” refers to a runnable Talend Task. Running a job creates a corresponding Talend Execution.

---

Installation

Install the package from PyPI:

pip install talend-task

CLI

talend_task is a CLI for running and monitoring jobs in Talend Cloud.

After installation, the talend_task command is available in your shell.

Select a job interactively or pass --job directly.

CLI Options:

$ talend_task --help
usage: talend_task [-h] [--debug] [--wait] [--activity] [--job NAME] [--timeout SECS]
                   [--poll-interval SECS]

Talend Cloud CLI

options:
  -h, --help            show this help message and exit
  --debug               enable debug logging
  --wait                wait for job to complete and return status
  --activity            show recent runs without executing job (cannot use --wait)
  --job NAME            job name
  --timeout SECS        timeout (requires --wait, default: none)
  --poll-interval SECS  polling interval (requires --wait, default: 5)

---

CLI Configuration

The CLI requires an Access Token and an API URL for your Talend Cloud region.

• API URL: Talend Cloud regional API endpoint.
• Access Token: Generate in Talend Management Console.

Configuration is provided via environment variables:

export API_URL=https://api.<region>.cloud.talend.com
export ACCESS_TOKEN=<access-token>

(region = us, eu, us-west, etc)

Alternatively, define them in a .env file in the current directory:

API_URL=https://api.<region>.cloud.talend.com
ACCESS_TOKEN=<access-token>

---

Example CLI Usage

Direct Mode

Run a job by providing --job <name>:

talend_task --wait --job Job1

Interactive Mode

Run the CLI without specifying a job to select and execute one from a menu:

talend_task --wait

Activity Mode

Show recent runs for a job without executing it:

talend_task --activity --job Job1

---

CLI Screenshots

Interactive Mode

Direct Mode

Activity Mode

---

Python API Client

Use the TalendClient class to interact with Talend Cloud from Python.

See the API documentation for details.

Example Client Usage

from talend_task import TalendClient

api_url = "https://api.us.cloud.talend.com"
access_token = "SECRET"

with TalendClient(api_url, access_token) as client:
    job_id = client.get_job_id("Job_123")
    status = client.run(job_id, wait=True)

---

Development

• Install as editable package with required development/testing dependencies:

  pip install --editable --group dev --group test .
  

• Run all tests:

  pytest
  

• Run linting and formatting:

  tox -e lint
  

• Run validation, linting, formatting, and all tests across all supported/installed Python environments:

  tox
  

Project Structure

./
├── .github/
│   └── workflows/
│       └── docs.yml
│       └── test.yml
├── src/
│   └── talend_task/
│       ├── __init__.py
│       ├── cli.py
│       └── talend_client.py
├── tests/
│   ├── test_cli.py
│   └── test_talend_client.py
├── pyproject.toml
└── tox.ini