[ 
https://issues.apache.org/jira/browse/AIRFLOW-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16737099#comment-16737099
 ] 

ribeyrolle nicolas commented on AIRFLOW-3632:
---------------------------------------------

This is also a point I was working on that point at my work, 

Being able to put replace_microseconds to false can do a temporary fix for the 
problem of triggering multiple time the same dag in < 1 second by the API.

By default the execution_date was truncated, the different dags have then the 
same execution_date and due to AIRFLOW-2319 / AIRFLOW-504 the call fail.

> dag_runs endpoint does not allow quick subsequent requests to same DAG
> ----------------------------------------------------------------------
>
>                 Key: AIRFLOW-3632
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-3632
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: api
>    Affects Versions: 1.10.1
>         Environment: MacOS and Linux
>            Reporter: Alpesh
>            Assignee: Alpesh
>            Priority: Major
>              Labels: easyfix
>         Attachments: test_api.sh
>
>
> The experimental API endpoint to start dag runs 
> (/dags/<string:dag_id>/dag_runs) does not allow quick subsequent requests to 
> run same dag as trigger_dag controller method does not pass 
> replace_microseconds argument to trigger_dag method of 
> common/experimental/trigger_dag.py.
> The attached shell script runs example_bash_operator in quick successions. 
> Only first request is accepted and subsequent requests are rejected with 
> message "Run id manual__xxxxxx already exists for dag id 
> example_bash_operator"



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to