[jira] [Commented] (AIRFLOW-711) stopping scheduler makes running sensor fail

["Fokko Driesprong (JIRA)" <ji...@apache.org>]

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

Fokko Driesprong commented on AIRFLOW-711:
------------------------------------------

Hi Jayesh,

What is the unexpected behaviour. The keyboard interrupt will stop the execution of Airflow and terminate the proces tree. Therefore it is expected that the sensor will stop executing. Please let me know if I miss something.

Cheers, Fokko

> stopping scheduler makes running sensor fail
> --------------------------------------------
>
>                 Key: AIRFLOW-711
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-711
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: core
>            Reporter: Jayesh
>
> on master brach, when i stop the scheduler ( by stopping it via my IDE ) it causes the sensor which is in running state and has run fine for couple of time already, will instantly fail with following error
> {code}
> [2016-12-21 19:25:08,588] {models.py:1347} ERROR - 
> Traceback (most recent call last):
>   File "/src/apache/airflow/airflow/models.py", line 1304, in run
>     result = task_copy.execute(context=context)
>   File "/src/apache/airflow/airflow/operators/sensors.py", line 79, in execute
>     sleep(self.poke_interval)
> KeyboardInterrupt
> {code}
> on IDE side i can see the following traceback generated
> {code}
> Traceback (most recent call last):
>   File "./airflow", line 28, in <module>
>     args.func(args)
>   File "/src/apache/airflow/airflow/bin/cli.py", line 370, in run
>     run_job.run()
>   File "/src/apache/airflow/airflow/jobs.py", line 202, in run
>     self._execute()
>   File "/src/apache/airflow/airflow/jobs.py", line 2028, in _execute
>     self.heartbeat()
>   File "/src/apache/airflow/airflow/jobs.py", line 177, in heartbeat
>     sleep(sleep_for)
> KeyboardInterrupt
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)