Removed deprecated workflow operations

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

Author: acroca

dapr/aio/clients/grpc/client.py

@@ -14,11 +14,9 @@
 """
 
 import asyncio
-import json
 import socket
 import time
 import uuid
-from datetime import datetime
 from typing import Any, Awaitable, Callable, Dict, List, Optional, Sequence, Text, Union
 from urllib.parse import urlencode
 from warnings import warn
@@ -57,7 +55,6 @@
     MetadataTuple,
     convert_dict_to_grpc_dict_of_any,
     convert_value_to_struct,
-    getWorkflowRuntimeStatus,
     to_bytes,
     validateNotBlankString,
     validateNotNone,
@@ -80,12 +77,10 @@
     GetBulkSecretResponse,
     GetMetadataResponse,
     GetSecretResponse,
-    GetWorkflowResponse,
     InvokeMethodResponse,
     QueryResponse,
     QueryResponseItem,
     RegisteredComponents,
-    StartWorkflowResponse,
     StateResponse,
     TopicEventResponse,
     TryLockResponse,
@@ -1493,321 +1488,6 @@ async def decrypt(self, data: Union[str, bytes], options: DecryptOptions):
         resp_stream = self._stub.DecryptAlpha1(req_iterator)
         return DecryptResponse(resp_stream)
 
-    async def start_workflow(
-        self,
-        workflow_component: str,
-        workflow_name: str,
-        input: Optional[Union[Any, bytes]] = None,
-        instance_id: Optional[str] = None,
-        workflow_options: Optional[Dict[str, str]] = dict(),
-        send_raw_bytes: bool = False,
-    ) -> StartWorkflowResponse:
-        """Starts a workflow.
-        Deprecated: use dapr-ext-workflow instead
-
-        Args:
-            workflow_component (str): the name of the workflow component
-                                that will run the workflow. e.g. `dapr`.
-            workflow_name (str): the name of the workflow that will be executed.
-            input (Optional[Union[Any, bytes]]): the input that the workflow will receive.
-                                             The input value will be serialized to JSON
-                                             by default. Use the send_raw_bytes param
-                                             to send unencoded binary input.
-            instance_id (Optional[str]): the name of the workflow instance,
-                                e.g. `order_processing_workflow-103784`.
-            workflow_options (Optional[Dict[str, str]]): the key-value options
-                                that the workflow will receive.
-            send_raw_bytes (bool) if true, no serialization will be performed on the input
-                                bytes
-
-        Returns:
-            :class:`StartWorkflowResponse`: Instance ID associated with the started workflow
-        """
-        # Warnings and input validation
-        warn(
-            'This Workflow API (Beta) method is deprecated and will be removed in a future version. Use the dapr-ext-workflow package instead.',
-            UserWarning,
-            stacklevel=2,
-        )
-        validateNotBlankString(
-            instance_id=instance_id,
-            workflow_component=workflow_component,
-            workflow_name=workflow_name,
-        )
-
-        if instance_id is None:
-            instance_id = str(uuid.uuid4())
-
-        if isinstance(input, bytes) and send_raw_bytes:
-            encoded_data = input
-        else:
-            try:
-                encoded_data = json.dumps(input).encode('utf-8') if input is not None else bytes([])
-            except TypeError:
-                raise DaprInternalError('start_workflow: input data must be JSON serializable')
-            except ValueError as e:
-                raise DaprInternalError(f'start_workflow JSON serialization error: {e}')
-
-        # Actual start workflow invocation
-        req = api_v1.StartWorkflowRequest(
-            instance_id=instance_id,
-            workflow_component=workflow_component,
-            workflow_name=workflow_name,
-            options=workflow_options,
-            input=encoded_data,
-        )
-
-        try:
-            response = self._stub.StartWorkflowBeta1(req)
-            return StartWorkflowResponse(instance_id=response.instance_id)
-        except grpc.aio.AioRpcError as err:
-            raise DaprInternalError(err.details())
-
-    async def get_workflow(self, instance_id: str, workflow_component: str) -> GetWorkflowResponse:
-        """Gets information on a workflow.
-        Deprecated: use dapr-ext-workflow instead
-
-        Args:
-            instance_id (str): the ID of the workflow instance,
-                                e.g. `order_processing_workflow-103784`.
-            workflow_component (str): the name of the workflow component
-                                that will run the workflow. e.g. `dapr`.
-
-        Returns:
-            :class:`GetWorkflowResponse`: Instance ID associated with the started workflow
-        """
-        # Warnings and input validation
-        warn(
-            'This Workflow API (Beta) method is deprecated and will be removed in a future version. Use the dapr-ext-workflow package instead.',
-            UserWarning,
-            stacklevel=2,
-        )
-        validateNotBlankString(instance_id=instance_id, workflow_component=workflow_component)
-        # Actual get workflow invocation
-        req = api_v1.GetWorkflowRequest(
-            instance_id=instance_id, workflow_component=workflow_component
-        )
-
-        try:
-            resp = self._stub.GetWorkflowBeta1(req)
-            # not found workflows return no error, but empty status
-            if resp.runtime_status == '':
-                raise DaprInternalError('no such instance exists')
-            if resp.created_at is None:
-                resp.created_at = datetime.now
-            if resp.last_updated_at is None:
-                resp.last_updated_at = datetime.now
-            return GetWorkflowResponse(
-                instance_id=instance_id,
-                workflow_name=resp.workflow_name,
-                created_at=resp.created_at,
-                last_updated_at=resp.last_updated_at,
-                runtime_status=getWorkflowRuntimeStatus(resp.runtime_status),
-                properties=resp.properties,
-            )
-        except grpc.aio.AioRpcError as err:
-            raise DaprInternalError(err.details())
-
-    async def terminate_workflow(self, instance_id: str, workflow_component: str) -> DaprResponse:
-        """Terminates a workflow.
-        Deprecated: use dapr-ext-workflow instead
-
-        Args:
-            instance_id (str): the ID of the workflow instance, e.g.
-                                `order_processing_workflow-103784`.
-            workflow_component (str): the name of the workflow component
-                                that will run the workflow. e.g. `dapr`.
-        Returns:
-            :class:`DaprResponse` gRPC metadata returned from callee
-
-        """
-        # Warnings and input validation
-        warn(
-            'This Workflow API (Beta) method is deprecated and will be removed in a future version. Use the dapr-ext-workflow package instead.',
-            UserWarning,
-            stacklevel=2,
-        )
-        validateNotBlankString(instance_id=instance_id, workflow_component=workflow_component)
-        # Actual terminate workflow invocation
-        req = api_v1.TerminateWorkflowRequest(
-            instance_id=instance_id, workflow_component=workflow_component
-        )
-
-        try:
-            _, call = self._stub.TerminateWorkflowBeta1.with_call(req)
-            return DaprResponse(headers=call.initial_metadata())
-        except grpc.aio.AioRpcError as err:
-            raise DaprInternalError(err.details())
-
-    async def raise_workflow_event(
-        self,
-        instance_id: str,
-        workflow_component: str,
-        event_name: str,
-        event_data: Optional[Union[Any, bytes]] = None,
-        send_raw_bytes: bool = False,
-    ) -> DaprResponse:
-        """Raises an event on a workflow.
-        Deprecated: use dapr-ext-workflow instead
-
-        Args:
-            instance_id (str): the ID of the workflow instance,
-                                e.g. `order_processing_workflow-103784`.
-            workflow_component (str): the name of the workflow component
-                                that will run the workflow. e.g. `dapr`.
-            event_name (str): the name of the event to be raised on
-                                the workflow.
-            event_data (Optional[Union[Any, bytes]]): the input that the workflow will receive.
-                                             The input value will be serialized to JSON
-                                             by default. Use the send_raw_bytes param
-                                             to send unencoded binary input.
-            send_raw_bytes (bool) if true, no serialization will be performed on the input
-                                bytes
-
-        Returns:
-            :class:`DaprResponse` gRPC metadata returned from callee
-        """
-        # Warnings and input validation
-        warn(
-            'This Workflow API (Beta) method is deprecated and will be removed in a future version. Use the dapr-ext-workflow package instead.',
-            UserWarning,
-            stacklevel=2,
-        )
-        validateNotBlankString(
-            instance_id=instance_id, workflow_component=workflow_component, event_name=event_name
-        )
-        if isinstance(event_data, bytes) and send_raw_bytes:
-            encoded_data = event_data
-        else:
-            if event_data is not None:
-                try:
-                    encoded_data = (
-                        json.dumps(event_data).encode('utf-8')
-                        if event_data is not None
-                        else bytes([])
-                    )
-                except TypeError:
-                    raise DaprInternalError(
-                        'raise_workflow_event:\
-                                             event_data must be JSON serializable'
-                    )
-                except ValueError as e:
-                    raise DaprInternalError(f'raise_workflow_event JSON serialization error: {e}')
-                encoded_data = json.dumps(event_data).encode('utf-8')
-            else:
-                encoded_data = bytes([])
-        # Actual workflow raise event invocation
-        req = api_v1.raise_workflow_event(
-            instance_id=instance_id,
-            workflow_component=workflow_component,
-            event_name=event_name,
-            event_data=encoded_data,
-        )
-
-        try:
-            _, call = self._stub.RaiseEventWorkflowBeta1.with_call(req)
-            return DaprResponse(headers=call.initial_metadata())
-        except grpc.aio.AioRpcError as err:
-            raise DaprInternalError(err.details())
-
-    async def pause_workflow(self, instance_id: str, workflow_component: str) -> DaprResponse:
-        """Pause a workflow.
-        Deprecated: use dapr-ext-workflow instead
-
-            Args:
-                instance_id (str): the ID of the workflow instance,
-                                    e.g. `order_processing_workflow-103784`.
-                workflow_component (str): the name of the workflow component
-                                    that will run the workflow. e.g. `dapr`.
-
-        Returns:
-            :class:`DaprResponse` gRPC metadata returned from callee
-
-        """
-        # Warnings and input validation
-        warn(
-            'This Workflow API (Beta) method is deprecated and will be removed in a future version. Use the dapr-ext-workflow package instead.',
-            UserWarning,
-            stacklevel=2,
-        )
-        validateNotBlankString(instance_id=instance_id, workflow_component=workflow_component)
-        # Actual pause workflow invocation
-        req = api_v1.PauseWorkflowRequest(
-            instance_id=instance_id, workflow_component=workflow_component
-        )
-
-        try:
-            _, call = self._stub.PauseWorkflowBeta1.with_call(req)
-
-            return DaprResponse(headers=call.initial_metadata())
-        except grpc.aio.AioRpcError as err:
-            raise DaprInternalError(err.details())
-
-    async def resume_workflow(self, instance_id: str, workflow_component: str) -> DaprResponse:
-        """Resumes a workflow.
-        Deprecated: use dapr-ext-workflow instead
-
-        Args:
-            instance_id (str): the ID of the workflow instance,
-                                e.g. `order_processing_workflow-103784`.
-            workflow_component (str): the name of the workflow component
-                                that will run the workflow. e.g. `dapr`.
-
-        Returns:
-            :class:`DaprResponse` gRPC metadata returned from callee
-        """
-        # Warnings and input validation
-        warn(
-            'This Workflow API (Beta) method is deprecated and will be removed in a future version. Use the dapr-ext-workflow package instead.',
-            UserWarning,
-            stacklevel=2,
-        )
-        validateNotBlankString(instance_id=instance_id, workflow_component=workflow_component)
-        # Actual resume workflow invocation
-        req = api_v1.ResumeWorkflowRequest(
-            instance_id=instance_id, workflow_component=workflow_component
-        )
-
-        try:
-            _, call = self._stub.ResumeWorkflowBeta1.with_call(req)
-
-            return DaprResponse(headers=call.initial_metadata())
-        except grpc.aio.AioRpcError as err:
-            raise DaprInternalError(err.details())
-
-    async def purge_workflow(self, instance_id: str, workflow_component: str) -> DaprResponse:
-        """Purges a workflow.
-        Deprecated: use dapr-ext-workflow instead
-
-            Args:
-                instance_id (str): the ID of the workflow instance,
-                                    e.g. `order_processing_workflow-103784`.
-                workflow_component (str): the name of the workflow component
-                                    that will run the workflow. e.g. `dapr`.
-
-        Returns:
-            :class:`DaprResponse` gRPC metadata returned from callee
-        """
-        # Warnings and input validation
-        warn(
-            'This Workflow API (Beta) method is deprecated and will be removed in a future version. Use the dapr-ext-workflow package instead.',
-            UserWarning,
-            stacklevel=2,
-        )
-        validateNotBlankString(instance_id=instance_id, workflow_component=workflow_component)
-        # Actual purge workflow invocation
-        req = api_v1.PurgeWorkflowRequest(
-            instance_id=instance_id, workflow_component=workflow_component
-        )
-
-        try:
-            _, call = self._stub.PurgeWorkflowBeta1.with_call(req)
-
-            return DaprResponse(headers=call.initial_metadata())
-
-        except grpc.aio.AioRpcError as err:
-            raise DaprInternalError(err.details())
-
     async def converse_alpha1(
         self,
         name: str,