[jira] [Commented] (AIRFLOW-221) Improve task instance timeout logic to work in LocalExecutor

["Maxime Beauchemin (JIRA)" <ji...@apache.org>]

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

Maxime Beauchemin commented on AIRFLOW-221:
-------------------------------------------

BaseOperator.timeout is handled using the context manager defined in airflow.utils.timeout. This uses an os signal approach which for some reason doesn't always play well with sub processes, which LocalExecutor uses. In those cases the timeout isn't enforce and only logs an error message as a fallback.

A more generic approach would be to modify BaseJob to support timeout and expose and `def on_timeout:` method to be implement by derivatives.

> Improve task instance timeout logic to work in LocalExecutor
> ------------------------------------------------------------
>
>                 Key: AIRFLOW-221
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-221
>             Project: Apache Airflow
>          Issue Type: Bug
>            Reporter: Maxime Beauchemin
>




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)