如果在Airflow DAG中尝试使用try_number宏将其转换为整数时出现问题,可以尝试使用Python的int函数手动转换。以下是一个示例代码:
from airflow import DAG from airflow.operators.bash_operator import BashOperator
dag = DAG('example_dag', default_args=default_args)
with dag: convert_string_to_int = BashOperator( task_id='convert_string_to_int', bash_command='echo {{ try_number(run_id) | default(0) }}', ) convert_string_to_int.dag = dag