update airflow variable using Variable.set()-CodePudding

I would like to update my value for key something in my nested airflow variable. Normally it is just Variable.set(key,new_value) but how do you do if it is nested?

{
  "vars": {
    "task1_args": "Task 1"
    "something": "Task something"
  }
}

CodePudding user response：

Assuming your data is a JSON object, you can do

data["vars"]["something"] = "something else"

CodePudding user response：

Just as usual - read variable, set the key, write variable:

Something like:

Variable.set('variable',Variable.get('variable')['key']='value')