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 op, job
from dagster_twilio import twilio_resource
import os

@op(required_resource_keys={'twilio'})
def my_op(context):
    context.resources.ssh.sftp_get("/path/to/remote.csv", "path/to/local.csv")

@job(resource_defs={
    'twilio': twilio_resource.configured({
        'account_sid': 'my_sid',
        'auth_token': os.environ['TWILIO_AUTH_TOKEN'],
    })
})
def my_job():
    my_op()

About Twilio

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