Merge release-1.16 branch changes to Main (#851)

* 1.16.0-rc1

Signed-off-by: Elena Kolevska <[email protected]>

* [Conversation API - Alpha2] Add new tool calling capability (#822) (#832)

* initial



* fixes after proto change upstream



* minor name changes and cleanup unused function



* refactors, updates to readme, linting



* feedback



* feedback, updates



* fix import in examples



* cleanup, import, lint, more conversation helpers



* clarify README, minor test import changes, copyright



* feedback DRY test_conversation file



* lint



* move conversation classes in _response module to conversation module.

Some example README refactor/lint



* minor readme change



* Update daprdocs/content/en/python-sdk-docs/python-client.md




* lint



* updates to fix issue with tool calling helper when dealing with classes instead of dataclasses, and also with serializatin output of the tool back to the LLM



* coalesce conv helper tests, fix typing lint



* make indent line method doc more dev friendly




* tackle some feedback, still missing unit tests



* add unit test to convert_value_to_struct



* more unit tests per feedback



* make async version of unit test conversation



* add some information how to run markdown tests with a different runtime



* ran tox -e ruff, even though tox -e flake8 was fine



* add tests to increase coverage in conversation and conversation_helpers that codecov pointed out



* add more information on execute registered tools, also added more tests for them to validate



* fix test failing on py 1.13. Merge two unit test files per feedback



* Linter



* fix typing issue with UnionType in py3.9



---------

Signed-off-by: Filinto Duran <[email protected]>
Signed-off-by: Elena Kolevska <[email protected]>
Co-authored-by: Albert Callarisa <[email protected]>
Co-authored-by: Elena Kolevska <[email protected]>
Co-authored-by: Elena Kolevska <[email protected]>

* update docs with tool calling helpers info (#838)

Signed-off-by: Filinto Duran <[email protected]>

* 1.16.0rc2

Signed-off-by: Elena Kolevska <[email protected]>

* use latest durabletask (#840)

Signed-off-by: Cassandra Coyle <[email protected]>

* 1.16.0

Signed-off-by: Elena Kolevska <[email protected]>

* Adds support for interceptors and concurrency_options arguments in the workflow engine (#841)

Signed-off-by: Albert Callarisa <[email protected]>

* Implement multi-app workflows (#844)

* feat: Adds support for cross-app calls.

Signed-off-by: Albert Callarisa <[email protected]>

* Use durabletask alpha.9

Signed-off-by: Albert Callarisa <[email protected]>

* Added examples for error scenarios in multi-app workflow

Signed-off-by: Albert Callarisa <[email protected]>

* Remove unnecessary hardcoded ports

Signed-off-by: Albert Callarisa <[email protected]>

---------

Signed-off-by: Albert Callarisa <[email protected]>

* chore: Rename wait_until_ready to wait_for_sidecar (#843)

Signed-off-by: Albert Callarisa <[email protected]>
Co-authored-by: Elena Kolevska <[email protected]>

* 1.16.1rc1 (#846)

Signed-off-by: Albert Callarisa <[email protected]>

---------

Signed-off-by: Elena Kolevska <[email protected]>
Signed-off-by: Filinto Duran <[email protected]>
Signed-off-by: Cassandra Coyle <[email protected]>
Signed-off-by: Albert Callarisa <[email protected]>
Co-authored-by: Elena Kolevska <[email protected]>
Co-authored-by: Filinto Duran <[email protected]>
Co-authored-by: Albert Callarisa <[email protected]>
Co-authored-by: Elena Kolevska <[email protected]>
Co-authored-by: Albert Callarisa <[email protected]>

Author: 4 people

README.md

@@ -53,7 +53,7 @@ pip3 install dapr-ext-fastapi
 
 ```sh
 # Install Dapr client sdk
-pip3 install dapr-dev
+pip3 install dapr
 
 # Install Dapr gRPC AppCallback service extension
 pip3 install dapr-ext-grpc-dev

dapr/aio/clients/grpc/client.py

@@ -153,7 +153,7 @@ def __init__(
             max_grpc_message_length (int, optional): The maximum grpc send and receive
                 message length in bytes.
         """
-        DaprHealth.wait_until_ready()
+        DaprHealth.wait_for_sidecar()
         self.retry_policy = retry_policy or RetryPolicy()
 
         useragent = f'dapr-sdk-python/{__version__}'

dapr/aio/clients/grpc/subscription.py

@@ -51,7 +51,7 @@ async def outgoing_request_iterator():
 
     async def reconnect_stream(self):
         await self.close()
-        DaprHealth.wait_until_ready()
+        DaprHealth.wait_for_sidecar()
         print('Attempting to reconnect...')
         await self.start()
 

dapr/clients/grpc/client.py

@@ -145,7 +145,7 @@ def __init__(
                 message length in bytes.
             retry_policy (RetryPolicy optional): Specifies retry behaviour
         """
-        DaprHealth.wait_until_ready()
+        DaprHealth.wait_for_sidecar()
         self.retry_policy = retry_policy or RetryPolicy()
 
         useragent = f'dapr-sdk-python/{__version__}'

dapr/clients/grpc/subscription.py

@@ -65,7 +65,7 @@ def outgoing_request_iterator():
 
     def reconnect_stream(self):
         self.close()
-        DaprHealth.wait_until_ready()
+        DaprHealth.wait_for_sidecar()
         print('Attempting to reconnect...')
         self.start()
 

dapr/clients/health.py

@@ -15,6 +15,7 @@
 import urllib.request
 import urllib.error
 import time
+from warnings import warn
 
 from dapr.clients.http.conf import DAPR_API_TOKEN_HEADER, USER_AGENT_HEADER, DAPR_USER_AGENT
 from dapr.clients.http.helpers import get_api_url
@@ -24,6 +25,15 @@
 class DaprHealth:
     @staticmethod
     def wait_until_ready():
+        warn(
+            'This method is deprecated. Use DaprHealth.wait_for_sidecar instead.',
+            DeprecationWarning,
+            stacklevel=2,
+        )
+        DaprHealth.wait_for_sidecar()
+
+    @staticmethod
+    def wait_for_sidecar():
         health_url = f'{get_api_url()}/healthz/outbound'
         headers = {USER_AGENT_HEADER: DAPR_USER_AGENT}
         if settings.DAPR_API_TOKEN is not None:

dapr/clients/http/client.py

@@ -51,7 +51,7 @@ def __init__(
             timeout (int, optional): Timeout in seconds, defaults to 60.
             headers_callback (lambda: Dict[str, str]], optional): Generates header for each request.
         """
-        DaprHealth.wait_until_ready()
+        DaprHealth.wait_for_sidecar()
 
         self._timeout = aiohttp.ClientTimeout(total=timeout)
         self._serializer = message_serializer

dapr/version/version.py

@@ -13,4 +13,4 @@
 limitations under the License.
 """
 
-__version__ = '1.15.0.dev'
+__version__ = '1.16.1rc1'

dev-requirements.txt

@@ -15,7 +15,7 @@ Flask>=1.1
 # needed for auto fix
 ruff===0.2.2
 # needed for dapr-ext-workflow
-durabletask-dapr >= 0.2.0a7
+durabletask-dapr >= 0.2.0a9
 # needed for .env file loading in examples
 python-dotenv>=1.0.0
 # needed for enhanced schema generation from function features

examples/demo_actor/demo_actor/requirements.txt

@@ -1 +1 @@
-dapr-ext-fastapi-dev>=1.15.0.dev
+dapr-ext-fastapi>=1.16.1rc1