ask/kombu — Issue #78: function' object has no attribute '_close'
Author: PonasNiekas
Created: 2011-11-04 14:56:54+00:00
State: open

I started getting the following warning message from celery workers.

kombu 1.4.3
celery 2.3.3

Here's a traceback:

INFO/PoolWorker-1] after forker raised exception 'function' object has no attribute '_close'
WARNING/PoolWorker-1] Traceback (most recent call last):
WARNING/PoolWorker-1] File "/usr/lib/python2.6/multiprocessing/util.py", line 130, in _run_after_forkers
WARNING/PoolWorker-1] func(obj)
WARNING/PoolWorker-1] File "/usr/local/lib/python2.6/dist-packages/celery/app/base.py", line 351, in _after_fork
WARNING/PoolWorker-1] self._pool.force_close_all()
WARNING/PoolWorker-1] File "/usr/local/lib/python2.6/dist-packages/kombu/connection.py", line 704, in force_close_all
WARNING/PoolWorker-1] self.close_resource(res)
WARNING/PoolWorker-1] File "/usr/local/lib/python2.6/dist-packages/kombu/connection.py", line 762, in close_resource
WARNING/PoolWorker-1] resource._close()
WARNING/PoolWorker-1] AttributeError: 'function' object has no attribute '_close'
INFO/PoolWorker-1] child process calling self.run()

Don't know if it's related, but I started getting the following exception occasionally in celery logs as well:

[2011-11-04 14:23:00,024: WARNING/PoolWorker-67] Exception
[2011-11-04 14:23:00,024: WARNING/PoolWorker-67] socket
[2011-11-04 14:23:00,024: WARNING/PoolWorker-67] .
[2011-11-04 14:23:00,024: WARNING/PoolWorker-67] error
[2011-11-04 14:23:00,024: WARNING/PoolWorker-67] :
[2011-11-04 14:23:00,025: WARNING/PoolWorker-67] (107, 'Transport endpoint is not connected')
[2011-11-04 14:23:00,025: WARNING/PoolWorker-67] in
[2011-11-04 14:23:00,025: WARNING/PoolWorker-67] >
[2011-11-04 14:23:00,025: WARNING/PoolWorker-67] ignored

Anyone knows what's going on ?

--
Lauris