Définir une tâche SLA
Après avoir complété le site SLA pour l'ensemble du flux de travail, vous vous rendez compte que vous n'avez besoin du timing SLA que pour une tâche spécifique et non pour l'ensemble du flux de travail.
Les bibliothèques Airflow appropriées sont importées pour vous.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Importez l'objet
timedelta. - Ajoutez une durée de 3 heures à la tâche (
sla).
Exercice interactif pratique
Essayez cet exercice en complétant cet exemple de code.
# Import the timedelta object
____
test_dag = DAG('test_workflow', start_date=datetime(2024,1,20), schedule_interval=None)
# Create the task with the SLA
task1 = BashOperator(task_id='first_task',
____=____,
bash_command='initialize_data.sh',
dag=test_dag)