gistfile1.txt

(Pdb) w
  /tve/bin/airflow(23)<module>()
-> args.func(args)
  /tve/lib/python2.7/site-packages/airflow/bin/cli.py(455)scheduler()
-> job.run()
  /tve/lib/python2.7/site-packages/airflow/jobs.py(173)run()
-> self._execute()
  /tve/lib/python2.7/site-packages/airflow/jobs.py(765)_execute()
-> executor.end()
  /tve/lib/python2.7/site-packages/airflow/executors/local_executor.py(75)end()
-> self.queue.join()
  /tve/lib/python2.7/multiprocessing/queues.py(342)join()
-> self._cond.wait()
  /tve/lib/python2.7/multiprocessing/synchronize.py(246)wait()
-> self._wait_semaphore.acquire(True, timeout)
> /tve/bin/airflow(11)handle_pdb()
-> def handle_pdb(sig, frame):
(Pdb) u
> /tve/lib/python2.7/multiprocessing/synchronize.py(246)wait()
-> self._wait_semaphore.acquire(True, timeout)
(Pdb) a
self = <Condition(<RLock(None, 0)>, 1)>
timeout = None
(Pdb) u
> /tve/lib/python2.7/multiprocessing/queues.py(342)join()
-> self._cond.wait()
(Pdb) u
> /tve/lib/python2.7/site-packages/airflow/executors/local_executor.py(75)end()
-> self.queue.join()
(Pdb) a
self = <airflow.executors.local_executor.LocalExecutor object at 0x7f6be0110410>
(Pdb) u
> /tve/lib/python2.7/site-packages/airflow/jobs.py(765)_execute()
-> executor.end()
(Pdb) q
Traceback (most recent call last):
  File "/tve/bin/airflow", line 23, in <module>
    args.func(args)
  File "/tve/lib/python2.7/site-packages/airflow/bin/cli.py", line 455, in scheduler
    job.run()
  File "/tve/lib/python2.7/site-packages/airflow/jobs.py", line 173, in run
    self._execute()
  File "/tve/lib/python2.7/site-packages/airflow/jobs.py", line 765, in _execute
    executor.end()
  File "/tve/lib/python2.7/site-packages/airflow/executors/local_executor.py", line 75, in end
    self.queue.join()
  File "/tve/lib/python2.7/multiprocessing/queues.py", line 342, in join
    self._cond.wait()
  File "/tve/lib/python2.7/multiprocessing/synchronize.py", line 246, in wait
    self._wait_semaphore.acquire(True, timeout)
OSError: [Errno 0] Error