You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "ASF subversion and git services (JIRA)" <ji...@apache.org> on 2017/04/12 18:57:41 UTC

[jira] [Commented] (AIRFLOW-1074) Do not count queued tasks in scheduler concurrency check

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

ASF subversion and git services commented on AIRFLOW-1074:
----------------------------------------------------------

Commit 8f9f5084bfdc2aa4017fee12e22d2e94672765ba in incubator-airflow's branch refs/heads/master from [~saguziel]
[ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=8f9f508 ]

[AIRFLOW-1074] Don't count queued tasks for concurrency limits

There may be orphaned tasks queued but not in a
running dag run that
will not cleared. We should not count these as
they will interfere.

I hate to do this, but I changed my mind on
counting queued tasks.

1. Queued tasks that are actually queued generally
get set to running pretty quickly.
2. Because of the worker-side check, we won't
actually pass concurrency.

I don't think the queued thing is a big deal
because of this, I'm more worried about orphaned
tasks that are in QUEUED state but not in a
running dag_run (so they wont get reset)
interfering with concurrency.

There may be orphaned tasks queued but not in a
running dag run that
will not cleared. We should not count these as
they will interfere.

Closes #2221 from saguziel/aguziel-concurrency-2


> Do not count queued tasks in scheduler concurrency check
> --------------------------------------------------------
>
>                 Key: AIRFLOW-1074
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1074
>             Project: Apache Airflow
>          Issue Type: Bug
>            Reporter: Alex Guziel
>




--
This message was sent by Atlassian JIRA
(v6.3.15#6346)