Update GRPC failure to new proto error (#952)

* Update GRPC failure to new proto error

* Formatting

Author: tconley1428

core/src/worker/workflow/mod.rs

@@ -405,10 +405,9 @@ impl Workflows {
                                 ),
                                 force_cause: 0,
                             };
-                            // TODO: tim - Update workflow cause when API is ready
                             let new_outcome = FailedActivationWFTReport::Report(
                                 task_token,
-                                WorkflowTaskFailedCause::WorkflowWorkerUnhandledFailure,
+                                WorkflowTaskFailedCause::GrpcMessageTooLarge,
                                 failure,
                             );
                             self.handle_activation_failed(run_id, completion_time, new_outcome)

tests/cloud_tests.rs

@@ -7,6 +7,7 @@ use temporal_client::{
     Client, ClientOptionsBuilder, ClientTlsConfig, RetryClient, TlsConfig, WorkflowClientTrait,
 };
 use temporal_sdk::WfContext;
+use temporal_sdk_core_protos::temporal::api::enums::v1::WorkflowTaskFailedCause::GrpcMessageTooLarge;
 use temporal_sdk_core_protos::temporal::api::{
     enums::v1::{EventType, WorkflowTaskFailedCause::WorkflowWorkerUnhandledFailure},
     history::v1::history_event::Attributes::WorkflowTaskFailedEventAttributes,
@@ -76,8 +77,7 @@ async fn grpc_message_too_large_test() {
     assert!(starter.get_history().await.events.iter().any(|e| {
         e.event_type == EventType::WorkflowTaskFailed as i32
             && if let WorkflowTaskFailedEventAttributes(attr) = e.attributes.as_ref().unwrap() {
-                // TODO tim: Change to custom cause
-                attr.cause == WorkflowWorkerUnhandledFailure as i32
+                attr.cause == GrpcMessageTooLarge as i32
                     && attr.failure.as_ref().unwrap().message == "GRPC Message too large"
             } else {
                 false

tests/integ_tests/worker_tests.rs

@@ -15,13 +15,13 @@ use temporal_sdk_core_api::{
     errors::WorkerValidationError,
     worker::{PollerBehavior, WorkerConfigBuilder, WorkerVersioningStrategy},
 };
+use temporal_sdk_core_protos::temporal::api::enums::v1::WorkflowTaskFailedCause::GrpcMessageTooLarge;
 use temporal_sdk_core_protos::{
     coresdk::workflow_completion::{
         Failure, WorkflowActivationCompletion, workflow_activation_completion::Status,
     },
     temporal::api::{
-        enums::v1::{EventType, WorkflowTaskFailedCause::WorkflowWorkerUnhandledFailure},
-        failure::v1::Failure as InnerFailure,
+        enums::v1::EventType, failure::v1::Failure as InnerFailure,
         history::v1::history_event::Attributes::WorkflowTaskFailedEventAttributes,
     },
 };
@@ -188,8 +188,7 @@ async fn oversize_grpc_message() {
     assert!(starter.get_history().await.events.iter().any(|e| {
         e.event_type == EventType::WorkflowTaskFailed as i32
             && if let WorkflowTaskFailedEventAttributes(attr) = e.attributes.as_ref().unwrap() {
-                // TODO tim: Change to custom cause
-                attr.cause == WorkflowWorkerUnhandledFailure as i32
+                attr.cause == GrpcMessageTooLarge as i32
                     && attr.failure.as_ref().unwrap().message == "GRPC Message too large"
             } else {
                 false