Skip to content

Trigger Dag using API #10

@Oracy

Description

@Oracy

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 :)

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions