<p dir="auto"><strong>Apache Airflow version</strong>: 1.10.10</p>
<p dir="auto"><strong>Kubernetes version (if you are using kubernetes)</strong> (use <code class="notranslate">kubectl version</code>):<br>
Client Version: version.Info{Major:"1", Minor:"17", GitVersion:"v1.17.2", GitCommit:"59603c6e503c87169aea6106f57b9f242f64df89", GitTreeState:"clean", BuildDate:"2020-01-23T14:21:54Z", GoVersion:"go1.13.6", Compiler:"gc", Platform:"darwin/amd64"}<br>
Server Version: version.Info{Major:"1", Minor:"14+", GitVersion:"v1.14.9-eks-502bfb", GitCommit:"502bfb383169b124d87848f89e17a04b9fc1f6f0", GitTreeState:"clean", BuildDate:"2020-02-07T01:31:02Z", GoVersion:"go1.12.12", Compiler:"gc", Platform:"linux/amd64"}</p>
<p dir="auto"><strong>Environment</strong>: EKS - KubernetesExecutor</p>
<ul dir="auto">
<li><strong>Cloud provider or hardware configuration</strong>: AWS EKS</li>
<li><strong>OS</strong> (e.g. from /etc/os-release):</li>
<li><strong>Kernel</strong> (e.g. <code class="notranslate">uname -a</code>):</li>
<li><strong>Install tools</strong>: Docker image</li>
<li><strong>Others</strong>:</li>
</ul>
<p dir="auto"><strong>What happened</strong>:</p>
<p dir="auto">Sometimes the TriggerDagOperator will fail with the following error, when, in fact, it was successful in triggering the target DAG.</p>
<div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="Traceback (most recent call last):
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py&quot;, line 1228, in _execute_context
    cursor, statement, parameters, context
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.py&quot;, line 857, in do_executemany
    cursor.executemany(statement, parameters)
psycopg2.errors.UniqueViolation: duplicate key value violates unique constraint &quot;task_instance_pkey&quot;
DETAIL:  Key (task_id, dag_id, execution_date)=(&lt;task_id&gt;, &lt;dag_id&gt;, 2020-04-20 17:00:00+00) already exists.


The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/models/taskinstance.py&quot;, line 983, in _run_raw_task
    result = task_copy.execute(context=context)
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/operators/dagrun_operator.py&quot;, line 95, in execute
    replace_microseconds=False)
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/api/common/experimental/trigger_dag.py&quot;, line 141, in trigger_dag
    replace_microseconds=replace_microseconds,
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/api/common/experimental/trigger_dag.py&quot;, line 98, in _trigger_dag
    external_trigger=True,
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/utils/db.py&quot;, line 74, in wrapper
    return func(*args, **kwargs)
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/models/dag.py&quot;, line 1469, in create_dagrun
    run.verify_integrity(session=session)
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/utils/db.py&quot;, line 70, in wrapper
    return func(*args, **kwargs)
  File &quot;/usr/local/lib/python3.7/site-packages/airflow/models/dagrun.py&quot;, line 400, in verify_integrity
    session.commit()
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py&quot;, line 1036, in commit
    self.transaction.commit()
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py&quot;, line 503, in commit
    self._prepare_impl()
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py&quot;, line 482, in _prepare_impl
    self.session.flush()
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py&quot;, line 2496, in flush
    self._flush(objects)
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py&quot;, line 2637, in _flush
    transaction.rollback(_capture_exception=True)
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py&quot;, line 69, in __exit__
    exc_value, with_traceback=exc_tb,
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/util/compat.py&quot;, line 178, in raise_
    raise exception
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py&quot;, line 2597, in _flush
    flush_context.execute()
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/unitofwork.py&quot;, line 422, in execute
    rec.execute(self)
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/unitofwork.py&quot;, line 589, in execute
    uow,
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/persistence.py&quot;, line 245, in save_obj
    insert,
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/persistence.py&quot;, line 1083, in _emit_insert_statements
    c = cached_connections[connection].execute(statement, multiparams)
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py&quot;, line 984, in execute
    return meth(self, multiparams, params)
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/sql/elements.py&quot;, line 293, in _execute_on_connection
    return connection._execute_clauseelement(self, multiparams, params)
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py&quot;, line 1103, in _execute_clauseelement
    distilled_params,
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py&quot;, line 1288, in _execute_context
    e, statement, parameters, cursor, context
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py&quot;, line 1482, in _handle_dbapi_exception
    sqlalchemy_exception, with_traceback=exc_info[2], from_=e
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/util/compat.py&quot;, line 178, in raise_
    raise exception
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py&quot;, line 1228, in _execute_context
    cursor, statement, parameters, context
  File &quot;/usr/local/lib/python3.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.py&quot;, line 857, in do_executemany
    cursor.executemany(statement, parameters)
sqlalchemy.exc.IntegrityError: (psycopg2.errors.UniqueViolation) duplicate key value violates unique constraint &quot;task_instance_pkey&quot;
DETAIL:  Key (task_id, dag_id, execution_date)=(&lt;task_id&gt;, &lt;dag_id&gt;, 2020-04-20 17:00:00+00) already exists."><pre class="notranslate"><code class="notranslate">Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1228, in _execute_context
    cursor, statement, parameters, context
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.py", line 857, in do_executemany
    cursor.executemany(statement, parameters)
psycopg2.errors.UniqueViolation: duplicate key value violates unique constraint "task_instance_pkey"
DETAIL:  Key (task_id, dag_id, execution_date)=(&lt;task_id&gt;, &lt;dag_id&gt;, 2020-04-20 17:00:00+00) already exists.


The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/airflow/models/taskinstance.py", line 983, in _run_raw_task
    result = task_copy.execute(context=context)
  File "/usr/local/lib/python3.7/site-packages/airflow/operators/dagrun_operator.py", line 95, in execute
    replace_microseconds=False)
  File "/usr/local/lib/python3.7/site-packages/airflow/api/common/experimental/trigger_dag.py", line 141, in trigger_dag
    replace_microseconds=replace_microseconds,
  File "/usr/local/lib/python3.7/site-packages/airflow/api/common/experimental/trigger_dag.py", line 98, in _trigger_dag
    external_trigger=True,
  File "/usr/local/lib/python3.7/site-packages/airflow/utils/db.py", line 74, in wrapper
    return func(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airflow/models/dag.py", line 1469, in create_dagrun
    run.verify_integrity(session=session)
  File "/usr/local/lib/python3.7/site-packages/airflow/utils/db.py", line 70, in wrapper
    return func(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airflow/models/dagrun.py", line 400, in verify_integrity
    session.commit()
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py", line 1036, in commit
    self.transaction.commit()
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py", line 503, in commit
    self._prepare_impl()
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py", line 482, in _prepare_impl
    self.session.flush()
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py", line 2496, in flush
    self._flush(objects)
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py", line 2637, in _flush
    transaction.rollback(_capture_exception=True)
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py", line 69, in __exit__
    exc_value, with_traceback=exc_tb,
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/util/compat.py", line 178, in raise_
    raise exception
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/session.py", line 2597, in _flush
    flush_context.execute()
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/unitofwork.py", line 422, in execute
    rec.execute(self)
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/unitofwork.py", line 589, in execute
    uow,
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/persistence.py", line 245, in save_obj
    insert,
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/orm/persistence.py", line 1083, in _emit_insert_statements
    c = cached_connections[connection].execute(statement, multiparams)
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 984, in execute
    return meth(self, multiparams, params)
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/sql/elements.py", line 293, in _execute_on_connection
    return connection._execute_clauseelement(self, multiparams, params)
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1103, in _execute_clauseelement
    distilled_params,
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1288, in _execute_context
    e, statement, parameters, cursor, context
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1482, in _handle_dbapi_exception
    sqlalchemy_exception, with_traceback=exc_info[2], from_=e
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/util/compat.py", line 178, in raise_
    raise exception
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/engine/base.py", line 1228, in _execute_context
    cursor, statement, parameters, context
  File "/usr/local/lib/python3.7/site-packages/sqlalchemy/dialects/postgresql/psycopg2.py", line 857, in do_executemany
    cursor.executemany(statement, parameters)
sqlalchemy.exc.IntegrityError: (psycopg2.errors.UniqueViolation) duplicate key value violates unique constraint "task_instance_pkey"
DETAIL:  Key (task_id, dag_id, execution_date)=(&lt;task_id&gt;, &lt;dag_id&gt;, 2020-04-20 17:00:00+00) already exists.
</code></pre></div>
<p dir="auto"><strong>What you expected to happen</strong>:</p>
<p dir="auto">It seems like this could by some kind of race condition or perhaps an issue with rescheduling? I expect this to not happen or for there to be a check before attempting to triggering the DAG so as to not have a false positive.</p>
<p dir="auto"><strong>How to reproduce it</strong>:</p>
<p dir="auto">Really not sure how to reproduce, its a pretty strange bug.</p>
<p dir="auto"><strong>Anything else we need to know</strong>:</p>
<p dir="auto">It happens maybe 3-4 times a month.</p>
<p dir="auto"><strong>Apache Airflow version</strong>: v2.1.3</p>
<p dir="auto"><strong>OS</strong>: CentOS 7</p>
<p dir="auto"><strong>Apache Airflow Provider versions</strong>:</p>
<p dir="auto">apache-airflow-providers-amazon==1.0.0<br>
apache-airflow-providers-celery==1.0.0<br>
apache-airflow-providers-cncf-kubernetes==1.0.0<br>
apache-airflow-providers-docker==1.0.0<br>
apache-airflow-providers-elasticsearch==1.0.0<br>
apache-airflow-providers-ftp==1.0.0<br>
apache-airflow-providers-google==1.0.0<br>
apache-airflow-providers-grpc==1.0.0<br>
apache-airflow-providers-hashicorp==1.0.0<br>
apache-airflow-providers-http==1.0.0<br>
apache-airflow-providers-imap==1.0.0<br>
apache-airflow-providers-microsoft-azure==1.0.0<br>
apache-airflow-providers-mysql==1.0.0<br>
apache-airflow-providers-postgres==1.0.0<br>
apache-airflow-providers-redis==1.0.0<br>
apache-airflow-providers-sendgrid==1.0.0<br>
apache-airflow-providers-sftp==1.0.0<br>
apache-airflow-providers-slack==1.0.0<br>
apache-airflow-providers-sqlite==1.0.0<br>
apache-airflow-providers-ssh==1.0.0<br>
<strong>Deployment</strong>:<br>
docker-compose version 1.26.0</p>
<p dir="auto"><strong>What happened</strong>:<br>
There is a graphichal glitch here:<br>
<a target="_blank" rel="noopener noreferrer nofollow" href="https://user-images.githubusercontent.com/40305877/131122404-52c59f08-255e-450b-a5e2-eb0dc11073cf.png"><img src="https://user-images.githubusercontent.com/40305877/131122404-52c59f08-255e-450b-a5e2-eb0dc11073cf.png" alt="image" style="max-width: 100%;"></a></p>
<p dir="auto"><strong>What you expected to happen</strong>:</p>
<p dir="auto">It is just small CSS mismatch, it can be corrected by adding this to svg element:<br>
<strong>width: 100%;</strong></p>
<p dir="auto"><strong>How to reproduce it</strong>:</p>
<p dir="auto">Just open DAGs page.</p>
<p dir="auto"><strong>Anything else we need to know</strong>:<br>
I am using Airflow on daily bases and I like it.</p>
<p dir="auto"><strong>Are you willing to submit a PR?</strong><br>
Yes</p>