airflow/airflow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

01k6f98y6pqgdxm7baky7anbdy.py committed by groupuser

Browse Source
This commit is contained in:
airflow 2025-11-17 06:35:10 +00:00
parent 7ae8aff8c0
commit 1ef247a4fd
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dags/groupuser/01k6f98y6pqgdxm7baky7anbdy.py
View File

@ -79,6 +79,7 @@ def test_log():
tags=['debug', 'elasticsearch'], tags=['debug', 'elasticsearch'],
) as dag: ) as dag:
keep_pod_alive = BashOperator( keep_pod_alive = BashOperator(
task_id='keep_pod_alive_for_debug', task_id='keep_pod_alive_for_debug',
bash_command="echo 'Debugging pod...'; sleep 300; exit 1;", bash_command="echo 'Debugging pod...'; sleep 300; exit 1;",
@ -88,6 +89,8 @@ def test_log():
task_id='debug_es_logging', task_id='debug_es_logging',
python_callable=test_es_logging_airflow3, python_callable=test_es_logging_airflow3,
) )
keep_pod_alive >> test
return dag return dag
dag = test_log() dag = test_log()