How to save the json config trigger value in a python variable ?

[eikesf]

I'm trying to trigger my dag with config and in there i'm passing {"estado":"ES"} what a need to do is to take this value and save it in a python variable to use inside a python function, how i do this ?. I've seen some tutorials saying that the command is {{ dag_run.conf['estado'] }} but it only works when executing with a bash operator, also i tried to execute python subprocess but it didn't work.
Below is the image of my trigger dag w/ config in the airflow UI

Below is some of the ways that i tried to grab it

def get_estado(**kwargs):
        #estado = kwargs["estado"]
        #estado = dag_run.conf['estado']
        #estado={{dag_run.conf.get('estado')}}
        #estado = os.system("{{ dag_run.conf['estado'] }}")
        #bashcmd = "{{ dag_run.conf['estado'] }}"
        #process = subprocess.Popen(bashcmd, stdout=subprocess.PIPE)
        #estado, error = process.communicate()
        #estado = "PR"
        if(estado == 'ES'):
            nome_estado='ES'
            ip_estado='http://0.0.0.0'
        elif(estado == 'PR'):
            nome_estado='PR'
            ip_estado='http://1.1.1.1'
        elif(estado == 'RJ'):
            nome_estado='RJ'
            ip_estado=''
        elif(estado == 'SC'):
            nome_estado='SC'
            ip_estado=''
        elif(estado == 'SP'):
            nome_estado='SP'
            ip_estado=''
        else:
            nome_estado='Estado não cadastrado'
            ip_estado='O IP deste estado não foi cadastrado'
        return nome_estado, ip_estado

[potiuk]

You can only pass it via

https://airflow.apache.org/docs/apache-airflow/stable/dag-run.html?highlight=dag_run

Note: The parameters from dag_run.conf can only be used in a template field of an operator.

You have to add op_args or op_kwargs in your PythonOperator and pass it there.

[potiuk]

Yes. XCom.

[eikesf]

Do you have an example on how can i grab multiple values from one Xcom just like the one in my last comment ('ES', 'http://1.1.1.1/') ? i've tried to use by the index and it didn't work. What's the correct way to do it?

[potiuk]

Find it in the docs (it's easy).

[potiuk]

You can also find a lot of examples in the source code of airflow - just search for xcom in both cases. This way you will learn much better than by getting ready answer.

[eikesf]

I'll try to find and understant it. Thanks potiuk