ESC
All(0)
emoticon icon

No results found for the current search

  1. ✨ Kestra 0.22 adds plugin versioning, LDAP sync & cross-namespace file sharing Learn More

Item 1 of 1
Kestra, Open source declarative data orchestration
  • Product
    • Core Features
    • Enterprise Edition
    • Cloud EditionEarly Access
  • Solutions

      Capabilities

    • Declarative Orchestration
    • Automation Platform
    • Language Agnostic
    • Kestra's Terraform Provider
    • API-First
    • Platform Overview

      By Roles

    • Data Engineers
    • Software Engineers
    • Platform Engineers

      By Industries

    • Retail & Supply Chain
    • Healthcare & Pharmaceuticals
    • Automotive & Heavy Equipment
    • All use-cases

      Resources

    • About Us
    • Partner
    • FAQ
    • Community Overview
    • Community Contents
    • Customer Stories
  • Learn
    • Docs
    • Blog
    • Blueprints
    • Video Tutorials
    • How to guides
    • Why kestra
    • Quickstart installation guide.
  • Plugins
  • Pricing
  • Talk to us Get Started! Talk to Us
  • Core Features

    Explore Kestra's Core Capabilities

  • Enterprise Edition

    Security and Governance for Enterprise Needs

  • Cloud EditionEarly Access

    Register for the Cloud Edition

Capabilities

  • Declarative Orchestration

    Infrastructure as Code of All Your Workflows

  • Automation Platform

    Scheduling and Automation Made Easy

  • Language Agnostic

    Orchestrate business logic in any language

  • Kestra's Terraform Provider

    Deploy & manage all resources with Terraform

  • API-First

    Learn more about Kestra's API features

  • Platform Overview

    Powerful Capabilities from the UI

By Roles

  • Data Engineers
  • Software Engineers
  • Platform Engineers

By Industries

  • Retail & Supply Chain
  • Healthcare & Pharmaceuticals
  • Automotive & Heavy Equipment
  • All use-cases

Resources

  • About Us
  • Partner
  • FAQ
  • Community Overview
  • Community Contents
  • Customer Stories
  • Docs

    Everything Kestra

  • Blog

    Tutorials, Guides, Market Trends and More

  • Blueprints

    A Library of ready to use Workflows

  • Video Tutorials

    your favourite tutorials in video

  • How to guides

    Learn step by step how to address use-cases

  • Why kestra

    Trust kestra as your unified orchestration tool

  • Quickstart installation guide.

    Trust kestra as your unified orchestration tool

Search

Ctrl + K
  • Core
    • Debug
      • Tasks
        • Echo
        • Return
    • Kv
      • Tasks
        • Delete
        • Get
        • GetKeys
        • Set
    • Output
      • Tasks
        • OutputValues
    • Chart
      • Charts
        • Bar
        • Markdown
        • Pie
        • Table
        • TimeSeries
    • Execution App Block
      • App Blocks
        • CancelExecutionButton
        • CreateExecutionButton
        • CreateExecutionForm
        • DownloadLogsButton
        • Inputs
        • Logs
        • Outputs
        • ResumeExecutionButton
        • ResumeExecutionForm
        • TaskOutputs
    • Log
      • Tasks
        • Fetch
        • Log
        • PurgeLogs
    • Runner
      • Task Runners
        • Process
    • Condition
      • Conditions
        • DateTimeBetween
        • DayWeek
        • DayWeekInMonth
        • ExecutionFlow
        • ExecutionLabels
        • ExecutionNamespace
        • ExecutionOutputs
        • ExecutionStatus
        • Expression
        • FlowCondition
        • FlowNamespaceCondition
        • HasRetryAttempt
        • MultipleCondition
        • Not
        • Or
        • PublicHoliday
        • TimeBetween
        • Weekend
    • Trigger
      • Tasks
        • Toggle
      • Triggers
        • Flow
        • Schedule
        • ScheduleOnDates
        • Webhook
    • Core App Block
      • App Blocks
        • Alert
        • AutoRefresh
        • Button
        • Divider
        • Image
        • Loading
        • Markdown
        • RedirectTo
        • Stacktrace
        • Table
    • Flow
      • Tasks
        • AllowFailure
        • Dag
        • EachParallel
        • EachSequential
        • ForEach
        • ForEachItem
        • If
        • LoopUntil
        • Parallel
        • Pause
        • Sequential
        • Sleep
        • Subflow
        • Switch
        • Template
        • WorkingDirectory
    • App
      • Apps
        • Execution
    • Namespace
      • Tasks
        • DeleteFiles
        • DownloadFiles
        • UploadFiles
    • Data Filter
      • Data Filters
        • Executions
        • Logs
        • Metrics
    • Http
      • Tasks
        • Download
        • Request
      • Triggers
        • Trigger
    • Templating
      • Tasks
        • TemplatedTask
    • State
      • Tasks
        • Delete
        • Get
        • Set
    • Log (EE)
      • Tasks
        • AuditLogShipper
        • LogShipper
        • PurgeAuditLogs
      • Log Exporters
        • FileLogExporter
    • Docker
      • Task Runners
        • Docker
    • Execution
      • Tasks
        • Assert
        • Count
        • Exit
        • Fail
        • Labels
        • PurgeExecutions
        • Resume
    • Storage
      • Tasks
        • Concat
        • DeduplicateItems
        • Delete
        • FilterItems
        • LocalFiles
        • PurgeCurrentExecutionFiles
        • Reverse
        • Size
        • Split
        • Write
  • Actian Vector
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • Airbyte
    • Jobs
      • Tasks
        • Reset
        • Sync
    • Connections
      • Tasks
        • CheckStatus
        • Sync
  • Airflow
    • Tasks
      • TriggerDagRun
  • Amazon Redshift
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • AMQP
    • Tasks
      • Consume
      • CreateQueue
      • DeclareExchange
      • Publish
      • QueueBind
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Ansible
    • Tasks
      • AnsibleCLI
  • Apache Cassandra
    • Astradb
      • Tasks
        • Query
      • Triggers
        • Trigger
    • Standard
      • Tasks
        • Query
      • Triggers
        • Trigger
  • Apache Druid
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Apache Kafka
    • Tasks
      • Consume
      • Produce
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Apache Pinot
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Apache Pulsar
    • Tasks
      • Consume
      • Produce
      • Reader
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Apache Spark
    • Tasks
      • JarSubmit
      • PythonSubmit
      • RSubmit
      • SparkCLI
  • Apache Tika
    • Tasks
      • Parse
  • Arrow Flight SQL
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • AS400
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Atlassian Jira
    • Issues
      • Tasks
        • Create
        • CreateComment
        • UpdateFields
  • AWS
    • S3
      • Tasks
        • Copy
        • CreateBucket
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • Upload
      • Triggers
        • Trigger
    • Sns
      • Tasks
        • Publish
    • Emr
      • Tasks
        • CreateClusterAndSubmitSteps
        • DeleteCluster
        • SubmitSteps
    • Athena
      • Tasks
        • Query
    • Dynamodb
      • Tasks
        • DeleteItem
        • GetItem
        • PutItem
        • Query
        • Scan
    • Kinesis
      • Tasks
        • PutRecords
    • Lambda
      • Tasks
        • Invoke
    • Cli
      • Tasks
        • AwsCLI
    • Authentication
      • Tasks
        • EksToken
    • Eventbridge
      • Tasks
        • PutEvents
    • Sqs
      • Tasks
        • Consume
        • Publish
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Ecr
      • Tasks
        • GetAuthToken
  • AWS (EE)
    • Task Runners
      • Batch
    • Log Exporters
      • LogExporter
      • LogExporter
  • Azure
    • Cli
      • Tasks
        • AzCLI
    • Function
      • Tasks
        • HttpFunction
    • Table
      • Tasks
        • Bulk
        • Delete
        • Get
        • List
    • Authentication
      • Tasks
        • OauthAccessToken
    • Eventhubs
      • Tasks
        • Consume
        • Produce
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Datafactory
      • Tasks
        • CreateRun
    • Adls
      • Tasks
        • Delete
        • DeleteFiles
        • List
        • Read
        • Reads
        • SharedAccess
        • Upload
      • Triggers
        • Trigger
    • Job
      • Tasks
        • Create
    • Pool
      • Tasks
        • Resize
    • Blob
      • Tasks
        • Copy
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • SharedAccess
        • Upload
      • Triggers
        • Trigger
  • Azure (EE)
    • Tasks
      • Create
      • List
      • SharedAccess
    • Task Runners
      • Batch
    • Log Exporters
      • LogExporter
      • LogExporter
  • ClickHouse
    • Tasks
      • BulkInsert
      • ClickHouseLocalCLI
      • Queries
      • Query
    • Triggers
      • Trigger
  • CloudQuery
    • Tasks
      • CloudQueryCLI
      • Sync
  • Compression
    • Tasks
      • ArchiveCompress
      • ArchiveDecompress
      • FileCompress
      • FileDecompress
  • Couchbase
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Cryptography
    • Openpgp
      • Tasks
        • Decrypt
        • Encrypt
  • Databricks
    • SQL
      • Tasks
        • Query
    • DBFS
      • Tasks
        • Download
        • Upload
    • Job
      • Tasks
        • CreateJob
        • SubmitRun
    • Cluster
      • Tasks
        • CreateCluster
        • DeleteCluster
  • Datadog (EE)
    • Log Exporters
      • LogExporter
  • Dataform
    • Dataform CLI
      • Tasks
        • DataformCLI
  • DataHub
    • Tasks
      • Ingestion
  • DB2
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Dbt
    • Dbt CLI
      • Tasks
        • Build
        • Compile
        • DbtCLI
        • Deps
        • Freshness
        • List
        • Run
        • Seed
        • Setup
        • Snapshot
        • Test
    • Dbt Cloud
      • Tasks
        • CheckStatus
        • TriggerRun
  • Debezium DB2
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium Microsoft SQL Server
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium MongoDB
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium MySQL
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium Oracle
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium PostgreSQL
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Docker
    • Tasks
      • Build
      • Prune
      • Pull
      • Rm
      • Run
      • Stop
  • Dremio
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • DuckDB
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Elasticsearch
    • Tasks
      • Bulk
      • Esql
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • Elasticsearch (EE)
    • Log Exporters
      • LogExporter
  • File system
    • Ftps
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Ftp
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Smb
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Ssh
      • Tasks
        • Command
    • Sftp
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
  • Fivetran
    • Connectors
      • Tasks
        • Sync
  • Git
    • Tasks
      • Clone
      • Push
      • PushFlows
      • PushNamespaceFiles
      • Sync
      • SyncFlows
      • SyncNamespaceFiles
  • GitHub
    • Tasks
      • Search
      • Search
      • Comment
      • Create
      • Search
      • Create
      • Search
      • Search
      • Search
      • Search
  • Google Cloud
    • Cli
      • Tasks
        • GCloudCLI
    • Vertex AI
      • Tasks
        • ChatCompletion
        • CustomJob
        • MultimodalCompletion
        • TextCompletion
    • Dataproc Batches
      • Tasks
        • PySparkSubmit
        • RSparkSubmit
        • SparkSqlSubmit
        • SparkSubmit
    • Google Cloud Function
      • Tasks
        • HttpFunction
    • Firestore
      • Tasks
        • Delete
        • Get
        • Query
        • Set
    • Dataproc Clusters
      • Tasks
        • Create
        • Delete
    • Pub/Sub
      • Tasks
        • Consume
        • Publish
      • Triggers
        • RealtimeTrigger
        • Trigger
    • BigQuery
      • Tasks
        • Copy
        • CopyPartitions
        • CreateDataset
        • CreateTable
        • DeleteDataset
        • DeletePartitions
        • DeleteTable
        • ExtractToGcs
        • Load
        • LoadFromGcs
        • Query
        • StorageWrite
        • TableMetadata
        • UpdateDataset
        • UpdateTable
      • Triggers
        • Trigger
    • Kubernetes Engine (GKE)
      • Tasks
        • ClusterMetadata
    • Cloud Storage (GCS)
      • Tasks
        • Compose
        • Copy
        • CreateBucket
        • CreateBucketIamPolicy
        • Delete
        • DeleteBucket
        • DeleteList
        • Download
        • Downloads
        • List
        • UpdateBucket
        • Upload
      • Triggers
        • Trigger
    • Authentication
      • Tasks
        • OauthAccessToken
  • Google Cloud (EE)
    • Task Runners
      • Batch
      • CloudRun
    • Log Exporters
      • LogExporter
      • LogExporter
  • Google Workspace
    • Drive
      • Tasks
        • Create
        • Delete
        • Download
        • Export
        • List
        • Upload
    • Sheets
      • Tasks
        • CreateSpreadsheet
        • DeleteSpreadsheet
        • Load
        • Read
        • ReadRange
    • Calendar
      • Tasks
        • InsertEvent
  • GraalVM
    • Ruby
      • Tasks
        • Eval
        • FileTransform
    • Js
      • Tasks
        • Eval
        • FileTransform
    • Python
      • Tasks
        • Eval
        • FileTransform
  • Grok
    • Tasks
      • TransformItems
      • TransformValue
  • Groovy
    • Tasks
      • Eval
      • FileTransform
  • Hightouch
    • Tasks
      • Sync
  • Hubspot
    • Tasks
      • Create
  • Huggingface
    • Tasks
      • Inference
  • JBang
    • Tasks
      • Commands
      • Script
  • JSONata
    • Tasks
      • TransformItems
      • TransformValue
  • Julia
    • Tasks
      • Commands
      • Script
  • Jython
    • Tasks
      • Eval
      • FileTransform
  • Kubernetes
    • Tasks
      • PodCreate
      • Apply
  • Kubernetes (EE)
    • Task Runners
      • Kubernetes
  • LDAP
    • Tasks
      • Add
      • Delete
      • IonToLdif
      • LdifToIon
      • Modify
      • Search
  • Linear
    • Tasks
      • Create
  • Malloy CLI
    • Tasks
      • CLI
  • MariaDB
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Meilisearch
    • Tasks
      • DocumentAdd
      • DocumentGet
      • FacetSearch
      • Search
  • Microsoft SQL Server
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • MinIO
    • Tasks
      • Copy
      • CreateBucket
      • Delete
      • DeleteList
      • Download
      • Downloads
      • List
      • Upload
    • Triggers
      • Trigger
  • Modal
    • Modal CLI
      • Tasks
        • ModalCLI
  • MongoDB
    • Tasks
      • Bulk
      • Delete
      • Find
      • InsertOne
      • Load
      • Update
    • Triggers
      • Trigger
  • MQTT
    • Tasks
      • Publish
      • Subscribe
    • Triggers
      • RealtimeTrigger
      • Trigger
  • MySQL
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • Nashorn
    • Tasks
      • Eval
      • FileTransform
  • NATS
    • Tasks
      • Consume
      • Produce
      • CreateBucket
      • Delete
      • Get
      • Put
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Neo4j
    • Tasks
      • Batch
      • Query
  • New Relic (EE)
    • Log Exporters
      • LogExporter
  • Node
    • Scripts
      • Tasks
        • Node
  • Notifications
    • Teams
      • Tasks
        • TeamsExecution
        • TeamsIncomingWebhook
    • Mail
      • Tasks
        • MailExecution
        • MailSend
    • Sentry
      • Tasks
        • SentryAlert
        • SentryExecution
    • Telegram
      • Tasks
        • TelegramExecution
        • TelegramSend
    • Twilio
      • Tasks
        • TwilioAlert
        • TwilioExecution
    • Google
      • Tasks
        • GoogleChatExecution
        • GoogleChatIncomingWebhook
    • Sendgrid
      • Tasks
        • SendGridMailExecution
        • SendGridMailSend
    • Pagerduty
      • Tasks
        • PagerDutyAlert
        • PagerDutyExecution
    • Slack
      • Tasks
        • SlackExecution
        • SlackIncomingWebhook
    • Opsgenie
      • Tasks
        • OpsgenieAlert
        • OpsgenieExecution
    • Whatsapp
      • Tasks
        • WhatsAppExecution
        • WhatsAppIncomingWebhook
    • Discord
      • Tasks
        • DiscordExecution
        • DiscordIncomingWebhook
    • Zenduty
      • Tasks
        • ZendutyAlert
        • ZendutyExecution
    • Zulip
      • Tasks
        • ZulipExecution
        • ZulipIncomingWebhook
  • OpenAI
    • Tasks
      • ChatCompletion
      • CreateImage
  • OpenSearch
    • Tasks
      • Bulk
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • Opensearch (EE)
    • Log Exporters
      • LogExporter
  • Opentelemetry (EE)
    • Log Exporters
      • LogExporter
  • Oracle
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • PostgreSQL
    • Tasks
      • Batch
      • CopyIn
      • CopyOut
      • Queries
      • Query
    • Triggers
      • Trigger
  • Power BI
    • Tasks
      • RefreshGroupDataset
  • PowerShell
    • Tasks
      • Commands
      • Script
  • Python
    • Scripts
      • Tasks
        • Python
  • Redis
    • String
      • Tasks
        • Delete
        • Get
        • Increment
        • Set
        • Ttl
    • List
      • Tasks
        • ListPop
        • ListPush
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Pubsub
      • Tasks
        • Publish
  • Rockset
    • Tasks
      • Query
    • Triggers
      • Trigger
  • RScript
    • Tasks
      • Commands
      • Script
  • Ruby
    • Tasks
      • Commands
      • Script
  • Serialization
    • Xml
      • Tasks
        • IonToXml
        • XmlToIon
    • Csv
      • Tasks
        • CsvToIon
        • IonToCsv
    • Excel
      • Tasks
        • ExcelToIon
        • IonToExcel
    • Avro
      • Tasks
        • AvroToIon
        • IonToAvro
    • Parquet
      • Tasks
        • IonToParquet
        • ParquetToIon
    • Json
      • Tasks
        • IonToJson
        • JsonToIon
  • ServiceNow
    • Tasks
      • Get
      • Post
  • Shell
    • Scripts
      • Tasks
        • Bash
  • Singer
    • Targets
      • Tasks
        • AdswerveBigQuery
        • Csv
        • DatamillCoPostgres
        • GenericTarget
        • Json
        • MeltanoSnowflake
        • Oracle
        • PipelinewisePostgres
        • PipelinewiseRedshift
        • PipelinewiseSnowflake
        • SqlServer
    • Taps
      • Tasks
        • BigQuery
        • BingAds
        • ChargeBee
        • ExchangeRateHost
        • FacebookAds
        • Fastly
        • GenericTap
        • GitHub
        • Gitlab
        • GoogleAdwords
        • GoogleAnalytics
        • GoogleSearchConsole
        • HubSpot
        • Marketo
        • Netsuite
        • PipelinewiseMongoDb
        • PipelinewiseMysql
        • PipelinewiseOracle
        • PipelinewisePostgres
        • PipelinewiseSqlServer
        • Quickbooks
        • Recharge
        • SageIntacct
        • Salesforce
        • Shopify
        • Slack
        • Stripe
        • Zendesk
        • Zoom
  • Snowflake
    • Tasks
      • Download
      • Queries
      • Query
      • SnowflakeCLI
      • Upload
    • Triggers
      • Trigger
  • Soda
    • Tasks
      • Scan
  • Solace
    • Tasks
      • Consume
      • Produce
    • Triggers
      • Trigger
  • Splunk (EE)
    • Log Exporters
      • LogExporter
  • SQLite
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • SQLMesh
    • SQLMesh CLI
      • Tasks
        • SQLMeshCLI
  • SurrealDB
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Sybase
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Terraform
    • Tasks
      • TerraformCLI
  • Trino
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Typesense
    • Tasks
      • BulkIndex
      • DocumentGet
      • DocumentIndex
      • FacetSearch
      • Search
  • Vertica
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • Weaviate
    • Tasks
      • BatchCreate
      • Delete
      • Query
      • SchemaCreate
  • Zendesk
    • Tasks
      • Create
plugins

Python​Python

Table of Contents
  • Scripts
Contribute
  • Join us on Slack
  • YouTube
  • GitHub
  • Twitter
  • BlueSky
  • LinkedIn

Execute Python scripts as part of Kestra data workflows.

Scripts iconScripts
Kestra's logo

Open Source Declarative Data Orchestration

Get Kestra updates

Stay up to date with the latest features and changes to Kestra

Product
  • Platform Overview
  • Open Source
  • Enterprise Edition
  • Kestra Cloud
  • Pricing
Solutions
  • Use Cases
  • Declarative Orchestration
  • Automation Platform
  • API First
  • Code in Any Language
  • Terraform Provider
  • Airflow vs Kestra
  • Prefect vs Kestra
  • Dagster vs Kestra
  • AWS Step Functions vs Kestra
Community
  • Community Overview
  • Blog
  • Write for Us
  • Slack
  • GitHub
Docs
  • Documentation
  • Plugins
  • Blueprints
  • Getting Started
  • Administrator Guide
  • FAQ
Company
  • About Us
  • Careers Hiring!
  • Contact Us
  • Customer Stories
  • Partners Ecosystem

© 2025 Kestra Technologies. Developed with on 🌎.

Privacy Policy / Cookie Policy

Slack