Migrate from programmatic to streaming pub/sub subscriptions

[sicoyle]

Current Implementation

dapr-agents currently uses programmatic subscriptions with push-based delivery via the Dapr Python SDK's subscribe_with_handler method. The subscription logic is implemented in:

• dapr_agents/workflow/utils/registration.py (line 243: default subscription method, lines 490-495: subscription creation)

Proposed Change

Migrate to streaming subscriptions to:

• Eliminate the need to expose application ports for message delivery
• Reduce infrastructure overhead
• Improve reliability through persistent connections
• Enable runtime subscription/unsubscription capabilities

Streaming subscriptions use a persistent gRPC connection between the application and Dapr sidecar, allowing the application to pull messages rather than receiving push-based HTTP/gRPC calls.

References

• Dapr Pub/Sub Subscription Types

[SoulSniper-V2]

Hi, I'd like to work on this! I'll migrate the programmatic subscription to use streaming pub/sub as described.