airflow_api_plugin icon indicating copy to clipboard operation
airflow_api_plugin copied to clipboard

Trigger Dag using API

Open Oracy opened this issue 5 years ago • 0 comments

Context

I need to run an API using both Macro: {{ execution_date }} and {{ next_execution_date }} to run some queries, I am using this json below to POST:

Endpoint [POST]: http://localhost:8080/api/experimental/dags/exemplos-api_example/dag_runs Json:

{
    "dag_id" : "exemplos-api_example",
    "execution_date" : "2020-08-31T00:41:25"
}

Problem

When I trigger my dag, I am trying to access the Airflow Macros but {{ next_execution_date }} is the same as my current execution date :(

I have no idea how to fix that, I really need your help guys :)

I tried to add next_execution_date on json body, but with no success, I know if I pass this value using conf I can handle that, but I do have a lot of queries and files that depends from this variable, and the easy way and faster way is handle Macro variable.

Thanks in advance :)

Oracy avatar Sep 01 '20 16:09 Oracy