Riley Kuttruff created SDAP-410:
-----------------------------------
Summary: Granule Ingester fails on ack-ing RMQ message after
pipeline completion
Key: SDAP-410
URL: https://issues.apache.org/jira/browse/SDAP-410
Project: Apache Science Data Analytics Platform
Issue Type: Bug
Components: granule-ingester
Reporter: Riley Kuttruff
Seems to happen only when the pipeline runs for a very long time.
Traceback:
2022-11-10 00:57:02,974 [ERROR] [__main__::197] Shutting down because of an
unrecoverable error:
'NoneType' object has no attribute 'write'
Traceback (most recent call last):
File
"/opt/conda/lib/python3.7/site-packages/sdap_granule_ingester-1.0.0_SNAPSHOT-py3.7.egg/granule_ingester/consumer/MessageConsumer.py",
line 80, in _received_message
await message.ack()
File
"/opt/conda/lib/python3.7/site-packages/aio_pika-6.7.1-py3.7.egg/aio_pika/message.py",
line 582, in ack
delivery_tag=self.delivery_tag, multiple=multiple,
File
"/opt/conda/lib/python3.7/site-packages/aiormq-3.3.1-py3.7.egg/aiormq/channel.py",
line 436, in basic_ack
self.writer.write(
AttributeError: 'NoneType' object has no attribute 'write'
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/sdap/granule_ingester/main.py", line 191, in main
await consumer.start_consuming(args.max_threads)
File
"/opt/conda/lib/python3.7/site-packages/sdap_granule_ingester-1.0.0_SNAPSHOT-py3.7.egg/granule_ingester/consumer/MessageConsumer.py",
line 113, in start_consuming
raise e
File
"/opt/conda/lib/python3.7/site-packages/sdap_granule_ingester-1.0.0_SNAPSHOT-py3.7.egg/granule_ingester/consumer/MessageConsumer.py",
line 105, in start_consuming
pipeline_max_concurrency)
File
"/opt/conda/lib/python3.7/site-packages/sdap_granule_ingester-1.0.0_SNAPSHOT-py3.7.egg/granule_ingester/consumer/MessageConsumer.py",
line 92, in _received_message
await message.reject(requeue=True)
File
"/opt/conda/lib/python3.7/site-packages/aio_pika-6.7.1-py3.7.egg/aio_pika/message.py",
line 611, in reject
delivery_tag=self.delivery_tag, requeue=requeue,
File
"/opt/conda/lib/python3.7/site-packages/aiormq-3.3.1-py3.7.egg/aiormq/channel.py",
line 468, in basic_reject
self.writer.write(
AttributeError: 'NoneType' object has no attribute 'write'
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
