[
https://issues.apache.org/jira/browse/AIRFLOW-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Deavarajegowda M T updated AIRFLOW-5500:
----------------------------------------
Description:
Unable to trigger workflow with nested sub dags, getting following error:
sqlalchemy.exc.IntegrityError: (psycopg2.IntegrityError) duplicate key value
(dag_id,execution_date)=('dummy.task1.task_level1.task_level2','2019-09-10
13:00:27+00:00') violates unique constraint "dag_run_dag_id_execution_date_key"
trigger_dag for nested sub_dags is called twice.
fix:
in airflow/api/common/experimental/trigger_dag.py -
while populating subdags for a dag, each subdag's subdags is also populated to
main dag.
So no need to repopulate subdags for each subdag separately.
was:
Unable to trigger workflow with nested sub dags, getting following error:
sqlalchemy.exc.IntegrityError: (psycopg2.IntegrityError) duplicate key value
(dag_id,execution_date)=('dummy.task1.task_level1.task_level2','2019-09-10
13:00:27+00:00') violates unique constraint "dag_run_dag_id_execution_date_key"
trigger_dag for nested sub_dags is called twice.
> Bug in trigger api endpoint
> ----------------------------
>
> Key: AIRFLOW-5500
> URL: https://issues.apache.org/jira/browse/AIRFLOW-5500
> Project: Apache Airflow
> Issue Type: Bug
> Components: api
> Affects Versions: 1.10.1
> Reporter: Deavarajegowda M T
> Priority: Critical
> Attachments: 3level.py
>
>
> Unable to trigger workflow with nested sub dags, getting following error:
> sqlalchemy.exc.IntegrityError: (psycopg2.IntegrityError) duplicate key value
> (dag_id,execution_date)=('dummy.task1.task_level1.task_level2','2019-09-10
> 13:00:27+00:00') violates unique constraint
> "dag_run_dag_id_execution_date_key"
> trigger_dag for nested sub_dags is called twice.
>
> fix:
> in airflow/api/common/experimental/trigger_dag.py -
> while populating subdags for a dag, each subdag's subdags is also populated
> to main dag.
> So no need to repopulate subdags for each subdag separately.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
