Skip to content

GitLab

A
Airflow
Commit ce6bbd15 authored by Margrenzo Gunawan's avatar Margrenzo Gunawan 💬
Browse files
Options

fix

parent e6540b4c
Show whitespace changes
Inline Side-by-side
Showing with 6 additions and 0 deletions
1_t24.py
View file @ ce6bbd15
...@@ -287,6 +287,12 @@ with DAG("APJ_1_T24", ...@@ -287,6 +287,12 @@ with DAG("APJ_1_T24",
).expand_kwargs( ).expand_kwargs(
XComArg(csv_clean_syntax), XComArg(csv_clean_syntax),
) )
ds_syntax_copy = PythonOperator(
task_id='csv_clean_syntax',
python_callable=ds_syntax_copy
)
ds_csv_to_table = PythonOperator.partial( ds_csv_to_table = PythonOperator.partial(
task_id="ds_csv_to_table", task_id="ds_csv_to_table",
python_callable=ds_csv_to_table, python_callable=ds_csv_to_table,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment