Kashif Khan

[Pyamqp] Intial TODOS Clean Up

1

* `ws.close` on async does close the socket in the library -> [link](https://github.com/websocket-client/websocket-client/blob/61171591b08ee031e02cc6cb129952259062f502/websocket/_core.py#L4580) * I kept the py2 comment in `_transport.py` about `from os import set_cloexec`. Looks like its not...

Originally posted by @dobizz over [here](https://github.com/Azure/azure-sdk-for-python/issues/26715) - **Package Name**: azure.functions.ServiceBusMessage - **Package Version**: ``` azure-core==1.25.1 azure-functions==1.11.2 azure-servicebus==7.8.0 ``` - **Operating System**: Windows 10 Pro (Build 19044.2006) - **Python Version**: 3.9.0...

[Pyamqp] Investigate coordination of receive task and client call back

1

Today we are using two concurrently running background tasks to do the follow * Receive messages from EH or SB and populate a buffer * Callback task that reads from...

[Pyamqp] Investigate Asyncio Story

1

In pyamqp currently we are using futures for a lot of tasks to be run concurrently and be treated as fire n forget. This has caused some issues with tasks...

notes: * `async PartitionContext` comes from `azure.eventhub.aio._eventprocessor` while sync comes from `azure.eventhubcallable` * `on_event` expects an `Optional[EventData]`. Why would we even invoke the callable if the EventData was None ?...

[Azure AMQP] Typing

34

Part 1 of pyamqp update for typing. I also brought in typing from Anna's branch. The other bits will come after this

MyPy Complains About "TracerProvider" has no attribute "add_span_processor"

1

When running mypy 1.8 on some of our samples, an error is generated saying that `"TracerProvider" has no attribute "add_span_processor"` From the looks of it, seems like [get_tracer_provider](https://github.com/open-telemetry/opentelemetry-python/blob/ac3c189ad40b3e482eda3cbfedd2d03312a20d4d/opentelemetry-api/src/opentelemetry/trace/__init__.py#L533) is returning...

[AMQP] Testing

12

# Description Please add an informative description that covers that changes made by the pull request and link all relevant issues. If an SDK is being regenerated based on a...

[SB] Fix Message Completion on Management Link

32

Fixes an issue in azure amqp where messages received on one receiver could not be settled on another receiver. Typically this is not possible but using the management link as...