10_read_variable_dag.py

from airflow import DAG  # noqa
from airflow.decorators import dag
from airflow.operators.bash import BashOperator
from datetime import datetime

@dag(start_date=datetime(2023, 5, 1), schedule=None, catchup=False, tags=['yoba'])
def read_var_dag():
    taska_easy = BashOperator(
        task_id='bash_task_simple',
        bash_command='echo "using var in command {{ var.value.my_var }} as a full string"',
    )

    taska_easyan = BashOperator(
        task_id='bash_task_json',
        bash_command='echo "using var in command {{ var.json.my_var.my_key }} as a deserialized obj"',
    )

    taska_easy >> taska_easyan


_ = read_var_dag()

if __name__ == '__main__':
    _.test()

20_my_var.png

30_output_task_simple.png

31_output_task_json.png