Trigger pipelines from code, APIs, or events—run with precision, flexibility, and complete control

Mage gives you powerful orchestration tools to run data workflows exactly when and how you need them. Whether you’re coordinating complex dependencies, reacting to external events, or just aligning with business SLAs, Mage lets you trigger pipelines with surgical precision.

🔁 Multi-Trigger Flexibility

Attach multiple triggers to a single pipeline—each with unique schedules, runtime parameters, or events. Write the pipeline once, and reuse it for every scenario.

🌐 API & Event-Based Execution

Pipelines can be launched through REST APIs, webhooks, or streaming events, enabling true event-driven architectures and seamless integration with external systems.

⏰ Landing Times (Backsolving)

Need your pipeline to finish by a certain time? Just set a landing time—Mage automatically calculates when to start based on historical run durations to ensure timely delivery.

🧱 Trigger from Within Other Pipelines

Use orchestration blocks or simple Python code to trigger pipelines from other pipelines. Pass variables, monitor status, and chain workflows without extra overhead.

from mage_ai.orchestration.triggers.api import trigger_pipeline

  
def run(*args, **kwargs):
    trigger_pipeline(
        'pipeline_uuid',
        variables={'env': 'prod'},
        check_status=True,
        schedule_name='trigger_from_model_training',
    )

With Mage, you can orchestrate workflows that are modular, reactive, and always on time.