Added test for deprecated function to increase coverage

Signed-off-by: Albert Callarisa <albert@diagrid.io>

Author: acroca

tests/clients/test_dapr_grpc_client_async.py

@@ -29,13 +29,17 @@
 from dapr.clients.grpc._crypto import DecryptOptions, EncryptOptions
 from dapr.clients.grpc._helpers import to_bytes
 from dapr.clients.grpc._jobs import Job
-from dapr.clients.grpc._request import TransactionalStateOperation
+from dapr.clients.grpc._request import (
+    TransactionalStateOperation,
+    TransactionOperationType,
+)
 from dapr.clients.grpc._response import (
     ConfigurationItem,
     ConfigurationResponse,
     ConfigurationWatcher,
     DaprResponse,
     UnlockResponseStatus,
+    WorkflowRuntimeStatus,
 )
 from dapr.clients.grpc._state import Concurrency, Consistency, StateItem, StateOptions
 from dapr.common.pubsub.subscription import StreamInactiveError
@@ -565,6 +569,9 @@ async def test_transaction_then_get_states(self):
             operations=[
                 TransactionalStateOperation(key=key, data=value, etag='foo'),
                 TransactionalStateOperation(key=another_key, data=another_value),
+                TransactionalStateOperation(
+                    key=key, operation_type=TransactionOperationType.delete
+                ),
             ],
             transactional_metadata={'metakey': 'metavalue'},
         )
@@ -1763,6 +1770,38 @@ async def test_job_lifecycle(self):
 
         await dapr.close()
 
+    async def test_workflow_deprecated(self):
+        dapr = DaprGrpcClientAsync(f'{self.scheme}localhost:{self.grpc_port}')
+        workflow_name = 'test_workflow'
+        event_name = 'eventName'
+        instance_id = str(uuid.uuid4())
+        workflow_component = 'dapr'
+        input = 'paperclips'
+        event_data = 'cars'
+
+        # Start the workflow
+        start_response = await dapr.start_workflow(
+            instance_id=instance_id,
+            workflow_name=workflow_name,
+            workflow_component=workflow_component,
+            input=input,
+            workflow_options=None,
+        )
+        self.assertEqual(instance_id, start_response.instance_id)
+
+        # Get info on the workflow to check that it is running
+        get_response = await dapr.get_workflow(
+            instance_id=instance_id, workflow_component=workflow_component
+        )
+        self.assertEqual(WorkflowRuntimeStatus.RUNNING.value, get_response.runtime_status)
+
+        # Raise an event on the workflow.
+        await dapr.raise_workflow_event(instance_id, workflow_component, event_name, event_data)
+        get_response = await dapr.get_workflow(instance_id, workflow_component)
+        self.assertEqual(event_data, get_response.properties[instance_id].strip('""'))
+
+        await dapr.close()
+
 
 if __name__ == '__main__':
     unittest.main()