diff --git a/airflow/providers/mysql/example_dags/example_mysql.py b/airflow/providers/mysql/example_dags/example_mysql.py index 041853640240c..a41da05a24d89 100644 --- a/airflow/providers/mysql/example_dags/example_mysql.py +++ b/airflow/providers/mysql/example_dags/example_mysql.py @@ -34,16 +34,14 @@ # [START howto_operator_mysql] -drop_table_mysql_task = MySqlOperator( - task_id='create_table_mysql', sql=r"""DROP TABLE table_name;""", dag=dag -) +drop_table_mysql_task = MySqlOperator(task_id='drop_table_mysql', sql=r"""DROP TABLE table_name;""", dag=dag) # [END howto_operator_mysql] # [START howto_operator_mysql_external_file] mysql_task = MySqlOperator( - task_id='create_table_mysql_external_file', + task_id='drop_table_mysql_external_file', sql='/scripts/drop_table.sql', dag=dag, )