Skip to content

[ServiceBus] error running receive_deferred_message_queue.py sample in live test pipeline #16649

@swathipil

Description

@swathipil
  • Package Name: [azure-servicebus]
  • Package Version: 7.0.2
  • Operating System: Windows
  • Python Version: 3.9

Describe the bug
Running the receive_deferred_message_queue.py and receive_deferred_message_queue_async.py samples results in a MessageNotFoundError. This only happens randomly in the test pipeline, but I have not been able to reproduce it locally.

To Reproduce
Steps to reproduce the behavior:

  1. Run the azure - servicebus -test pipeline.

Expected behavior
The samples should run and the tests should pass.

Screenshots
Error log from the test pipeline:

INFO:root:Testing /mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/samples/async_samples/receive_deferred_message_queue_async.py
INFO:root:Command Array: ['/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/bin/python', '/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/samples/async_samples/receive_deferred_message_queue_async.py'], Target Working Directory: /mnt/vss/_work/1/s
Failed to complete mgmt operation.
Status code: 500
Message: b'Failed to lock one or more specified messages as they were not deferred messages. TrackingId:e30dbafe-3566-4010-a9dd-9b69b89f5813_B6, SystemTracker:sb-td52000762b65419c:Queue:***, Timestamp:2021-05-11T18:39:29'
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Deferring msg: Message to be deferred
Traceback (most recent call last):
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/samples/async_samples/receive_deferred_message_queue_async.py", line 54, in <module>
    loop.run_until_complete(main())
  File "/opt/hostedtoolcache/Python/3.9.4/x64/lib/python3.9/asyncio/base_events.py", line 642, in run_until_complete
    return future.result()
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/samples/async_samples/receive_deferred_message_queue_async.py", line 43, in main
    received_deferred_msg = await receiver.receive_deferred_messages(
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/aio/_servicebus_receiver_async.py", line 667, in receive_deferred_messages
    messages = await self._mgmt_request_response_with_retry(
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/aio/_base_handler_async.py", line 351, in _mgmt_request_response_with_retry
    return await self._do_retryable_operation(
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/aio/_base_handler_async.py", line 250, in _do_retryable_operation
    last_exception = await self._handle_exception(exception)
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/aio/_base_handler_async.py", line 198, in _handle_exception
    raise error
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/aio/_base_handler_async.py", line 246, in _do_retryable_operation
    return await operation(**kwargs)
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/aio/_base_handler_async.py", line 334, in _mgmt_request_response
    return await self._handler.mgmt_request_async(
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/uamqp/async_ops/client_async.py", line 318, in mgmt_request_async
    response = await asyncio.shield(
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/uamqp/async_ops/session_async.py", line 114, in mgmt_request_async
    return parse_response(status, response, description)
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/_common/mgmt_handlers.py", line 125, in deferred_message_op
    _handle_amqp_mgmt_error(
  File "/mnt/vss/_work/1/s/sdk/servicebus/azure-servicebus/.tox/samples/lib/python3.9/site-packages/azure/servicebus/exceptions.py", line 151, in _handle_amqp_mgmt_error
    raise _handle_amqp_exception_with_condition(
azure.servicebus.exceptions.MessageNotFoundError: Retrieving deferred messages failed. b'Failed to lock one or more specified messages as they were not deferred messages. TrackingId:e30dbafe-3566-4010-a9dd-9b69b89f5813_B6, SystemTracker:sb-td52000762b65419c:Queue:***, Timestamp:2021-05-11T18:39:29'. Error condition: com.microsoft:message-not-found. Status Code: 500.

Metadata

Metadata

Assignees

Labels

ClientThis issue points to a problem in the data-plane of the library.MessagingMessaging crewService Bustest-reliabilityIssue that causes tests to be unreliable

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions