ashb commented on a change in pull request #11335:
URL: https://github.com/apache/airflow/pull/11335#discussion_r511863077
##
File path: airflow/api_connexion/endpoints/task_instance_endpoint.py
##
@@ -286,9 +287,13 @@ def post_set_task_instances_state(dag_id, session):
ashb commented on a change in pull request #11335:
URL: https://github.com/apache/airflow/pull/11335#discussion_r511862369
##
File path: airflow/exceptions.py
##
@@ -126,6 +126,10 @@ class DuplicateTaskIdFound(AirflowException):
"""Raise when a Task with duplicate task_id
ashb commented on a change in pull request #11335:
URL: https://github.com/apache/airflow/pull/11335#discussion_r511861198
##
File path: airflow/api/common/experimental/__init__.py
##
@@ -32,9 +31,9 @@ def check_and_get_dag(dag_id: str, task_id: Optional[str] =
None) ->
ashb commented on a change in pull request #11335:
URL: https://github.com/apache/airflow/pull/11335#discussion_r511450726
##
File path: tests/jobs/test_scheduler_job.py
##
@@ -1407,7 +1414,9 @@ def
test_find_executable_task_instances_task_concurrency(self): # pylint: disab