Definindo um BashOperator com @task.bash

Uma tarefa Bash permite especificar qualquer comando ou script de shell e adicioná-lo a um fluxo de trabalho do Airflow. Isso pode ser um ótimo começo para implementar o Airflow no seu ambiente.

Você vinha executando alguns scripts manualmente para limpar dados (usando um script chamado cleanup.sh) antes de entregá-los aos seus colegas do time de Análise de Dados. À medida que mais dessas tarefas foram atribuídas a você, percebeu que está ficando difícil dar conta de executar tudo manualmente, sem falar em lidar com erros ou novas tentativas. Você quer implementar um script simples como um operador do Airflow.

Os objetos de dag e task do Airflow já foram importados.

Este exercício faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

Instruções do exercício

Use o decorador @task.bash para definir a tarefa.
Use o nome de método cleanup_task.
Faça a tarefa retornar cleanup.sh.

Exercício interativo prático

Experimente este exercício completando este código de exemplo.

@dag(
  dag_id='analytics_dag', 
  start_date=datetime(2026,1,1)
)
def analytics_dag():
  # Specify a Bash task
  @____
  def ____():
    return '____'
  
  # Run the task
  cleanup_task()

analytics_dag()

Editar e executar o código