AttributeError: 'NoneType' object has no attribute 'drain_events'

[Hyeuk Ryu]

Hi,

I've got the below error message when I ran event based risk simulation using v3.6.

The error occurred when i changed investigation_time from 50 to 500.

Please let me know how to avoid this error.
Thanks.


Regards,


Hyeuk

[2019-08-09 17:13:33,509 #317 WARNING] Building the loss curves and maps for each asset is deprecated: consider building the aggregate curves and maps with the ebrisk calculator instead
[2019-08-09 17:13:46,071 #317 CRITICAL]
Traceback (most recent call last):
File "/apps/openquake/3.6/src/oq-engine/openquake/calculators/base.py", line 194, in run
self.result = self.execute()
File "/apps/openquake/3.6/src/oq-engine/openquake/calculators/base.py", line 905, in execute
weight=get_weight
File "/apps/openquake/3.6/src/oq-engine/openquake/baselib/parallel.py", line 651, in apply
return cls(task, task_args, mon, distribute, progress).submit_all()
File "/apps/openquake/3.6/src/oq-engine/openquake/baselib/parallel.py", line 736, in submit_all
self.submit(*args)
File "/apps/openquake/3.6/src/oq-engine/openquake/baselib/parallel.py", line 727, in submit
res = submit[dist](self, func, args, monitor)
File "/apps/openquake/3.6/src/oq-engine/openquake/baselib/parallel.py", line 216, in celery_submit
return safetask.delay(func, args, self.task_no, monitor)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/celery/app/task.py", line 413, in delay
return self.apply_async(args, kwargs)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/celery/app/task.py", line 536, in apply_async
**options
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/celery/app/base.py", line 737, in send_task
amqp.send_task_message(P, name, message, **options)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/celery/utils/objects.py", line 91, in __exit__
return self._context.__exit__(*exc_info)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/messaging.py", line 239, in __exit__
self.release()
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/resource.py", line 105, in release
self.release(R)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/pools.py", line 74, in release
resource.__connection__.release()
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/resource.py", line 105, in release
self.release(R)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/resource.py", line 134, in release
self.close_resource(resource)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/connection.py", line 917, in close_resource
resource._close()
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/connection.py", line 324, in _close
self._do_close_self()
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/connection.py", line 314, in _do_close_self
self.maybe_close_channel(self._default_channel)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/kombu/connection.py", line 306, in maybe_close_channel
channel.close()
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/channel.py", line 225, in close
wait=spec.Channel.CloseOk,
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/abstract_channel.py", line 59, in send_method
return self.wait(wait, returns_tuple=returns_tuple)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/abstract_channel.py", line 79, in wait
self.connection.drain_events(timeout=timeout)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/connection.py", line 471, in drain_events
while not self.blocking_read(timeout):
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/connection.py", line 477, in blocking_read
return self.on_inbound_frame(frame)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/method_framing.py", line 55, in on_frame
callback(channel, method_sig, buf, None)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/connection.py", line 481, in on_inbound_method
method_sig, payload, content,
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/abstract_channel.py", line 128, in dispatch_method
listener(*args)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/channel.py", line 277, in _on_close
self._do_revive()
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/channel.py", line 164, in _do_revive
self.open()
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/channel.py", line 434, in open
spec.Channel.Open, 's', ('',), wait=spec.Channel.OpenOk,
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/abstract_channel.py", line 59, in send_method
return self.wait(wait, returns_tuple=returns_tuple)
File "/apps/openquake/3.6/oqenv/lib/python3.6/site-packages/amqp/abstract_channel.py", line 79, in wait
self.connection.drain_events(timeout=timeout)
AttributeError: 'NoneType' object has no attribute 'drain_events'

[Daniele Viganò]

You either run out of memory on a worker or RabbitMQ was not able too keep up with such amount of data (i.e. transfering too much data.

The calculation is too large. Unfortunately almost everyone that may help you with this is on vacation, so you need to be patient.

Cheers,
Daniele

--
You received this message because you are subscribed to the Google Groups "OpenQuake Users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to openquake-use...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/openquake-users/284a952f-6a66-4051-b3b6-d50cf97aa3dc%40googlegroups.com.

--

DANIELE VIGANÒ | System Administrator | Skype dennyv85 | +39 0382 5169882

GLOBAL EARTHQUAKE MODEL | working together to assess risk

GEM - globalquakemodel.org | T - @GEMwrld | F - GEMwrld

[Hyeuk Ryu]

Thanks, Daniele.

I managed to get it running by increasing the memory following your advice.

Regards,

Hyeuk

To unsubscribe from this group and stop receiving emails from it, send an email to openqua...@googlegroups.com.

To view this discussion on the web visit https://groups.google.com/d/msgid/openquake-users/284a952f-6a66-4051-b3b6-d50cf97aa3dc%40googlegroups.com.