Twilio | Dagster Integrations
Back to integrations
Dagster + Twilio

Dagster + Twilio

Integrate Twilio tasks into your data pipeline runs.

About this integration

Use your Twilio Account SID and Auth Token to build Twilio tasks right into your Dagster pipeline.

Installation

pip install dagster-twilio

Example

# Read the docs on Resources to learn more: https://docs.dagster.io/deployment/resources
from dagster import EnvVar, op, job
from dagster_twilio import twilio_resource
import os

@op
def my_op(twilio: TwilioResource):
    twilio.create_client().messages.create(
        to="+15551234567",
        from_="+15558901234",
        body="Hello world!"
    )

@job(resource_defs={
    "twilio": TwilioResource(
        account_sid="my_sid",
        auth_token=EnvVar("TWILIO_AUTH_TOKEN"),
    )
})
def my_job():
    my_op()

About Twilio

Twilio provides communication APIs for phone calls, text messages, and other communication functions.