[jira] [Created] (AIRFLOW-342) exception in 'airflow scheduler' : Connection reset by peer

["Hila Visan (JIRA)" <ji...@apache.org>]

Hila Visan created AIRFLOW-342:
----------------------------------

             Summary:  exception in 'airflow scheduler' : Connection reset by peer
                 Key: AIRFLOW-342
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-342
             Project: Apache Airflow
          Issue Type: Bug
          Components: celery, scheduler
    Affects Versions: Airflow 1.7.1.3
         Environment: OS: Red Hat Enterprise Linux Server 7.2 (Maipo)
Python: 2.7.5
Airflow: 1.7.1.3
            Reporter: Hila Visan
            Assignee: Siddharth Anand


'airflow scheduler' command throws an exception when running it. 
Despite the exception, the workers run the tasks from the queues as expected.

Error details:
 
[2016-06-30 19:00:10,130] {jobs.py:758} ERROR - [Errno 104] Connection reset by peer
Traceback (most recent call last):
  File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 755, in _execute
    executor.heartbeat()
  File "/usr/lib/python2.7/site-packages/airflow/executors/base_executor.py", line 107, in heartbeat
    self.sync()
  File "/usr/lib/python2.7/site-packages/airflow/executors/celery_executor.py", line 74, in sync
    state = async.state
  File "/usr/lib/python2.7/site-packages/celery/result.py", line 394, in state
    return self._get_task_meta()['status']
  File "/usr/lib/python2.7/site-packages/celery/result.py", line 339, in _get_task_meta
    return self._maybe_set_cache(self.backend.get_task_meta(self.id))
  File "/usr/lib/python2.7/site-packages/celery/backends/amqp.py", line 163, in get_task_meta
    binding.declare()
  File "/usr/lib/python2.7/site-packages/kombu/entity.py", line 521, in declare
   self.exchange.declare(nowait)
  File "/usr/lib/python2.7/site-packages/kombu/entity.py", line 174, in declare
    nowait=nowait, passive=passive,
  File "/usr/lib/python2.7/site-packages/amqp/channel.py", line 615, in exchange_declare
    self._send_method((40, 10), args)
  File "/usr/lib/python2.7/site-packages/amqp/abstract_channel.py", line 56, in _send_method
    self.channel_id, method_sig, args, content,
  File "/usr/lib/python2.7/site-packages/amqp/method_framing.py", line 221, in write_method
    write_frame(1, channel, payload)
  File "/usr/lib/python2.7/site-packages/amqp/transport.py", line 182, in write_frame
    frame_type, channel, size, payload, 0xce,
  File "/usr/lib64/python2.7/socket.py", line 224, in meth
    return getattr(self._sock,name)(*args)
error: [Errno 104] Connection reset by peer
[2016-06-30 19:00:10,131] {jobs.py:759} ERROR - Tachycardia!




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