You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "ribeyrolle nicolas (JIRA)" <ji...@apache.org> on 2019/01/08 13:00:00 UTC
[jira] [Comment Edited] (AIRFLOW-3632) dag_runs endpoint does not
allow quick subsequent requests to same DAG
[ https://issues.apache.org/jira/browse/AIRFLOW-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16737099#comment-16737099 ]
ribeyrolle nicolas edited comment on AIRFLOW-3632 at 1/8/19 12:59 PM:
----------------------------------------------------------------------
This is also a point I was working on 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 API call fail.
was (Author: nipica):
This is also a point I was working on 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)