diff --git a/examples/spec/integration/converter_spec.rb b/examples/spec/integration/converter_spec.rb
index 21878c1f..0a97f075 100644
--- a/examples/spec/integration/converter_spec.rb
+++ b/examples/spec/integration/converter_spec.rb
@@ -19,7 +19,7 @@
   ensure
     Temporal.configure do |config|
       config.task_queue = task_queue
-      config.converter = Temporal::Configuration::DEFAULT_CONVERTER
+      config.payload_codec = Temporal::Configuration::DEFAULT_PAYLOAD_CODEC
     end
   end
 
diff --git a/lib/gen/temporal/api/common/v1/message_pb.rb b/lib/gen/temporal/api/common/v1/message_pb.rb
index ef18cc6e..52c50880 100644
--- a/lib/gen/temporal/api/common/v1/message_pb.rb
+++ b/lib/gen/temporal/api/common/v1/message_pb.rb
@@ -46,6 +46,16 @@
       optional :maximum_attempts, :int32, 4
       repeated :non_retryable_error_types, :string, 5
     end
+    add_message "temporal.api.common.v1.MeteringMetadata" do
+      optional :nonfirst_local_activity_execution_attempts, :uint32, 13
+    end
+    add_message "temporal.api.common.v1.WorkerVersionStamp" do
+      optional :build_id, :string, 1
+      optional :bundle_id, :string, 2
+    end
+    add_message "temporal.api.common.v1.WorkerVersionCapabilities" do
+      optional :build_id, :string, 1
+    end
   end
 end
 
@@ -63,6 +73,9 @@ module V1
         WorkflowType = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.common.v1.WorkflowType").msgclass
         ActivityType = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.common.v1.ActivityType").msgclass
         RetryPolicy = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.common.v1.RetryPolicy").msgclass
+        MeteringMetadata = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.common.v1.MeteringMetadata").msgclass
+        WorkerVersionStamp = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.common.v1.WorkerVersionStamp").msgclass
+        WorkerVersionCapabilities = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.common.v1.WorkerVersionCapabilities").msgclass
       end
     end
   end
diff --git a/lib/gen/temporal/api/enums/v1/failed_cause_pb.rb b/lib/gen/temporal/api/enums/v1/failed_cause_pb.rb
index e0e21568..4986e3ac 100644
--- a/lib/gen/temporal/api/enums/v1/failed_cause_pb.rb
+++ b/lib/gen/temporal/api/enums/v1/failed_cause_pb.rb
@@ -53,6 +53,7 @@
       value :SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED, 0
       value :SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_EXTERNAL_WORKFLOW_EXECUTION_NOT_FOUND, 1
       value :SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND, 2
+      value :SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_SIGNAL_COUNT_LIMIT_EXCEEDED, 3
     end
     add_enum "temporal.api.enums.v1.ResourceExhaustedCause" do
       value :RESOURCE_EXHAUSTED_CAUSE_UNSPECIFIED, 0
diff --git a/lib/gen/temporal/api/history/v1/message_pb.rb b/lib/gen/temporal/api/history/v1/message_pb.rb
index e2d6e2f4..2b0043ce 100644
--- a/lib/gen/temporal/api/history/v1/message_pb.rb
+++ b/lib/gen/temporal/api/history/v1/message_pb.rb
@@ -14,6 +14,7 @@
 require 'temporal/api/taskqueue/v1/message_pb'
 require 'temporal/api/update/v1/message_pb'
 require 'temporal/api/workflow/v1/message_pb'
+require 'temporal/api/sdk/v1/task_complete_metadata_pb'
 
 Google::Protobuf::DescriptorPool.generated_pool.build do
   add_file("temporal/api/history/v1/message.proto", :syntax => :proto3) do
@@ -94,7 +95,9 @@
       optional :started_event_id, :int64, 2
       optional :identity, :string, 3
       optional :binary_checksum, :string, 4
-      optional :worker_versioning_id, :message, 5, "temporal.api.taskqueue.v1.VersionId"
+      optional :worker_version, :message, 5, "temporal.api.common.v1.WorkerVersionStamp"
+      optional :sdk_metadata, :message, 6, "temporal.api.sdk.v1.WorkflowTaskCompletedMetadata"
+      optional :metering_metadata, :message, 13, "temporal.api.common.v1.MeteringMetadata"
     end
     add_message "temporal.api.history.v1.WorkflowTaskTimedOutEventAttributes" do
       optional :scheduled_event_id, :int64, 1
@@ -199,6 +202,7 @@
       optional :input, :message, 2, "temporal.api.common.v1.Payloads"
       optional :identity, :string, 3
       optional :header, :message, 4, "temporal.api.common.v1.Header"
+      optional :skip_generate_workflow_task, :bool, 5
     end
     add_message "temporal.api.history.v1.WorkflowExecutionTerminatedEventAttributes" do
       optional :reason, :string, 1
diff --git a/lib/gen/temporal/api/sdk/v1/task_complete_metadata_pb.rb b/lib/gen/temporal/api/sdk/v1/task_complete_metadata_pb.rb
new file mode 100644
index 00000000..281bd518
--- /dev/null
+++ b/lib/gen/temporal/api/sdk/v1/task_complete_metadata_pb.rb
@@ -0,0 +1,23 @@
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# source: temporal/api/sdk/v1/task_complete_metadata.proto
+
+require 'google/protobuf'
+
+Google::Protobuf::DescriptorPool.generated_pool.build do
+  add_file("temporal/api/sdk/v1/task_complete_metadata.proto", :syntax => :proto3) do
+    add_message "temporal.api.sdk.v1.WorkflowTaskCompletedMetadata" do
+      repeated :core_used_flags, :uint32, 1
+      repeated :lang_used_flags, :uint32, 2
+    end
+  end
+end
+
+module Temporalio
+  module Api
+    module Sdk
+      module V1
+        WorkflowTaskCompletedMetadata = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.sdk.v1.WorkflowTaskCompletedMetadata").msgclass
+      end
+    end
+  end
+end
diff --git a/lib/gen/temporal/api/taskqueue/v1/message_pb.rb b/lib/gen/temporal/api/taskqueue/v1/message_pb.rb
index 648e3e2b..053e5f67 100644
--- a/lib/gen/temporal/api/taskqueue/v1/message_pb.rb
+++ b/lib/gen/temporal/api/taskqueue/v1/message_pb.rb
@@ -8,6 +8,7 @@
 require 'google/protobuf/wrappers_pb'
 require 'dependencies/gogoproto/gogo_pb'
 require 'temporal/api/enums/v1/task_queue_pb'
+require 'temporal/api/common/v1/message_pb'
 
 Google::Protobuf::DescriptorPool.generated_pool.build do
   add_file("temporal/api/taskqueue/v1/message.proto", :syntax => :proto3) do
@@ -37,19 +38,15 @@
       optional :last_access_time, :message, 1, "google.protobuf.Timestamp"
       optional :identity, :string, 2
       optional :rate_per_second, :double, 3
-      optional :worker_versioning_id, :message, 4, "temporal.api.taskqueue.v1.VersionId"
+      optional :worker_version_capabilities, :message, 4, "temporal.api.common.v1.WorkerVersionCapabilities"
     end
     add_message "temporal.api.taskqueue.v1.StickyExecutionAttributes" do
       optional :worker_task_queue, :message, 1, "temporal.api.taskqueue.v1.TaskQueue"
       optional :schedule_to_start_timeout, :message, 2, "google.protobuf.Duration"
     end
-    add_message "temporal.api.taskqueue.v1.VersionIdNode" do
-      optional :version, :message, 1, "temporal.api.taskqueue.v1.VersionId"
-      optional :previous_compatible, :message, 2, "temporal.api.taskqueue.v1.VersionIdNode"
-      optional :previous_incompatible, :message, 3, "temporal.api.taskqueue.v1.VersionIdNode"
-    end
-    add_message "temporal.api.taskqueue.v1.VersionId" do
-      optional :worker_build_id, :string, 1
+    add_message "temporal.api.taskqueue.v1.CompatibleVersionSet" do
+      optional :version_set_id, :string, 1
+      repeated :build_ids, :string, 2
     end
   end
 end
@@ -65,8 +62,7 @@ module V1
         TaskQueuePartitionMetadata = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.taskqueue.v1.TaskQueuePartitionMetadata").msgclass
         PollerInfo = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.taskqueue.v1.PollerInfo").msgclass
         StickyExecutionAttributes = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.taskqueue.v1.StickyExecutionAttributes").msgclass
-        VersionIdNode = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.taskqueue.v1.VersionIdNode").msgclass
-        VersionId = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.taskqueue.v1.VersionId").msgclass
+        CompatibleVersionSet = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.taskqueue.v1.CompatibleVersionSet").msgclass
       end
     end
   end
diff --git a/lib/gen/temporal/api/workflow/v1/message_pb.rb b/lib/gen/temporal/api/workflow/v1/message_pb.rb
index f6405daa..470fd0a4 100644
--- a/lib/gen/temporal/api/workflow/v1/message_pb.rb
+++ b/lib/gen/temporal/api/workflow/v1/message_pb.rb
@@ -29,6 +29,7 @@
       optional :task_queue, :string, 13
       optional :state_transition_count, :int64, 14
       optional :history_size_bytes, :int64, 15
+      optional :most_recent_worker_version_stamp, :message, 16, "temporal.api.common.v1.WorkerVersionStamp"
     end
     add_message "temporal.api.workflow.v1.WorkflowExecutionConfig" do
       optional :task_queue, :message, 1, "temporal.api.taskqueue.v1.TaskQueue"
diff --git a/lib/gen/temporal/api/workflowservice/v1/request_response_pb.rb b/lib/gen/temporal/api/workflowservice/v1/request_response_pb.rb
index 7d8d6446..ab356996 100644
--- a/lib/gen/temporal/api/workflowservice/v1/request_response_pb.rb
+++ b/lib/gen/temporal/api/workflowservice/v1/request_response_pb.rb
@@ -26,6 +26,7 @@
 require 'temporal/api/update/v1/message_pb'
 require 'temporal/api/version/v1/message_pb'
 require 'temporal/api/batch/v1/message_pb'
+require 'temporal/api/sdk/v1/task_complete_metadata_pb'
 require 'google/protobuf/duration_pb'
 require 'google/protobuf/timestamp_pb'
 require 'dependencies/gogoproto/gogo_pb'
@@ -110,6 +111,9 @@
       optional :search_attributes, :message, 15, "temporal.api.common.v1.SearchAttributes"
       optional :header, :message, 16, "temporal.api.common.v1.Header"
       optional :request_eager_execution, :bool, 17
+      optional :continued_failure, :message, 18, "temporal.api.failure.v1.Failure"
+      optional :last_completion_result, :message, 19, "temporal.api.common.v1.Payloads"
+      optional :workflow_start_delay, :message, 20, "google.protobuf.Duration"
     end
     add_message "temporal.api.workflowservice.v1.StartWorkflowExecutionResponse" do
       optional :run_id, :string, 1
@@ -145,7 +149,7 @@
       optional :task_queue, :message, 2, "temporal.api.taskqueue.v1.TaskQueue"
       optional :identity, :string, 3
       optional :binary_checksum, :string, 4
-      optional :worker_versioning_id, :message, 5, "temporal.api.taskqueue.v1.VersionId"
+      optional :worker_version_capabilities, :message, 5, "temporal.api.common.v1.WorkerVersionCapabilities"
     end
     add_message "temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse" do
       optional :task_token, :bytes, 1
@@ -174,8 +178,10 @@
       optional :binary_checksum, :string, 7
       map :query_results, :string, :message, 8, "temporal.api.query.v1.WorkflowQueryResult"
       optional :namespace, :string, 9
-      optional :worker_versioning_id, :message, 10, "temporal.api.taskqueue.v1.VersionId"
+      optional :worker_version_stamp, :message, 10, "temporal.api.common.v1.WorkerVersionStamp"
       repeated :messages, :message, 11, "temporal.api.protocol.v1.Message"
+      optional :sdk_metadata, :message, 12, "temporal.api.sdk.v1.WorkflowTaskCompletedMetadata"
+      optional :metering_metadata, :message, 13, "temporal.api.common.v1.MeteringMetadata"
     end
     add_message "temporal.api.workflowservice.v1.RespondWorkflowTaskCompletedResponse" do
       optional :workflow_task, :message, 1, "temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse"
@@ -198,7 +204,7 @@
       optional :task_queue, :message, 2, "temporal.api.taskqueue.v1.TaskQueue"
       optional :identity, :string, 3
       optional :task_queue_metadata, :message, 4, "temporal.api.taskqueue.v1.TaskQueueMetadata"
-      optional :worker_versioning_id, :message, 5, "temporal.api.taskqueue.v1.VersionId"
+      optional :worker_version_capabilities, :message, 5, "temporal.api.common.v1.WorkerVersionCapabilities"
     end
     add_message "temporal.api.workflowservice.v1.PollActivityTaskQueueResponse" do
       optional :task_token, :bytes, 1
@@ -316,6 +322,7 @@
       optional :request_id, :string, 6
       optional :control, :string, 7
       optional :header, :message, 8, "temporal.api.common.v1.Header"
+      optional :skip_generate_workflow_task, :bool, 9
     end
     add_message "temporal.api.workflowservice.v1.SignalWorkflowExecutionResponse" do
     end
@@ -339,6 +346,8 @@
       optional :memo, :message, 17, "temporal.api.common.v1.Memo"
       optional :search_attributes, :message, 18, "temporal.api.common.v1.SearchAttributes"
       optional :header, :message, 19, "temporal.api.common.v1.Header"
+      optional :workflow_start_delay, :message, 20, "google.protobuf.Duration"
+      optional :skip_generate_workflow_task, :bool, 21
     end
     add_message "temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionResponse" do
       optional :run_id, :string, 1
@@ -514,6 +523,7 @@
       optional :build_id_based_versioning, :bool, 6
       optional :upsert_memo, :bool, 7
       optional :eager_workflow_start, :bool, 8
+      optional :sdk_metadata, :bool, 9
     end
     add_message "temporal.api.workflowservice.v1.ListTaskQueuePartitionsRequest" do
       optional :namespace, :string, 1
@@ -591,23 +601,44 @@
       repeated :schedules, :message, 1, "temporal.api.schedule.v1.ScheduleListEntry"
       optional :next_page_token, :bytes, 2
     end
-    add_message "temporal.api.workflowservice.v1.UpdateWorkerBuildIdOrderingRequest" do
+    add_message "temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequest" do
       optional :namespace, :string, 1
       optional :task_queue, :string, 2
-      optional :version_id, :message, 3, "temporal.api.taskqueue.v1.VersionId"
-      optional :previous_compatible, :message, 4, "temporal.api.taskqueue.v1.VersionId"
-      optional :become_default, :bool, 5
+      oneof :operation do
+        optional :add_new_build_id_in_new_default_set, :string, 3
+        optional :add_new_compatible_build_id, :message, 4, "temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequest.AddNewCompatibleVersion"
+        optional :promote_set_by_build_id, :string, 5
+        optional :promote_build_id_within_set, :string, 6
+      end
+    end
+    add_message "temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequest.AddNewCompatibleVersion" do
+      optional :new_build_id, :string, 1
+      optional :existing_compatible_build_id, :string, 2
+      optional :make_set_default, :bool, 3
     end
-    add_message "temporal.api.workflowservice.v1.UpdateWorkerBuildIdOrderingResponse" do
+    add_message "temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityResponse" do
+      optional :version_set_id, :string, 1
     end
-    add_message "temporal.api.workflowservice.v1.GetWorkerBuildIdOrderingRequest" do
+    add_message "temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityRequest" do
       optional :namespace, :string, 1
       optional :task_queue, :string, 2
-      optional :max_depth, :int32, 3
+      optional :max_sets, :int32, 3
+      optional :include_retirement_candidates, :bool, 4
+      optional :include_poller_compatibility, :bool, 5
+    end
+    add_message "temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse" do
+      repeated :major_version_sets, :message, 1, "temporal.api.taskqueue.v1.CompatibleVersionSet"
+      repeated :retirement_candidates, :message, 2, "temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse.RetirementCandidate"
+      repeated :active_versions_and_pollers, :message, 3, "temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse.VersionsWithCompatiblePollers"
+    end
+    add_message "temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse.RetirementCandidate" do
+      optional :build_id, :string, 1
+      optional :all_workflows_are_archived, :bool, 2
+      repeated :pollers, :message, 3, "temporal.api.taskqueue.v1.PollerInfo"
     end
-    add_message "temporal.api.workflowservice.v1.GetWorkerBuildIdOrderingResponse" do
-      optional :current_default, :message, 1, "temporal.api.taskqueue.v1.VersionIdNode"
-      repeated :compatible_leaves, :message, 2, "temporal.api.taskqueue.v1.VersionIdNode"
+    add_message "temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse.VersionsWithCompatiblePollers" do
+      optional :most_recent_build_id, :string, 1
+      repeated :pollers, :message, 2, "temporal.api.taskqueue.v1.PollerInfo"
     end
     add_message "temporal.api.workflowservice.v1.UpdateWorkflowExecutionRequest" do
       optional :namespace, :string, 1
@@ -668,6 +699,15 @@
       repeated :operation_info, :message, 1, "temporal.api.batch.v1.BatchOperationInfo"
       optional :next_page_token, :bytes, 2
     end
+    add_message "temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateRequest" do
+      optional :namespace, :string, 1
+      optional :update_ref, :message, 2, "temporal.api.update.v1.UpdateRef"
+      optional :identity, :string, 3
+      optional :wait_policy, :message, 4, "temporal.api.update.v1.WaitPolicy"
+    end
+    add_message "temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateResponse" do
+      optional :outcome, :message, 1, "temporal.api.update.v1.Outcome"
+    end
   end
 end
 
@@ -772,10 +812,13 @@ module V1
         DeleteScheduleResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.DeleteScheduleResponse").msgclass
         ListSchedulesRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.ListSchedulesRequest").msgclass
         ListSchedulesResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.ListSchedulesResponse").msgclass
-        UpdateWorkerBuildIdOrderingRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.UpdateWorkerBuildIdOrderingRequest").msgclass
-        UpdateWorkerBuildIdOrderingResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.UpdateWorkerBuildIdOrderingResponse").msgclass
-        GetWorkerBuildIdOrderingRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.GetWorkerBuildIdOrderingRequest").msgclass
-        GetWorkerBuildIdOrderingResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.GetWorkerBuildIdOrderingResponse").msgclass
+        UpdateWorkerBuildIdCompatibilityRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequest").msgclass
+        UpdateWorkerBuildIdCompatibilityRequest::AddNewCompatibleVersion = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequest.AddNewCompatibleVersion").msgclass
+        UpdateWorkerBuildIdCompatibilityResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityResponse").msgclass
+        GetWorkerBuildIdCompatibilityRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityRequest").msgclass
+        GetWorkerBuildIdCompatibilityResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse").msgclass
+        GetWorkerBuildIdCompatibilityResponse::RetirementCandidate = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse.RetirementCandidate").msgclass
+        GetWorkerBuildIdCompatibilityResponse::VersionsWithCompatiblePollers = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponse.VersionsWithCompatiblePollers").msgclass
         UpdateWorkflowExecutionRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.UpdateWorkflowExecutionRequest").msgclass
         UpdateWorkflowExecutionResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.UpdateWorkflowExecutionResponse").msgclass
         StartBatchOperationRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.StartBatchOperationRequest").msgclass
@@ -786,6 +829,8 @@ module V1
         DescribeBatchOperationResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.DescribeBatchOperationResponse").msgclass
         ListBatchOperationsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.ListBatchOperationsRequest").msgclass
         ListBatchOperationsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.ListBatchOperationsResponse").msgclass
+        PollWorkflowExecutionUpdateRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateRequest").msgclass
+        PollWorkflowExecutionUpdateResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateResponse").msgclass
       end
     end
   end
diff --git a/lib/gen/temporal/api/workflowservice/v1/service_services_pb.rb b/lib/gen/temporal/api/workflowservice/v1/service_services_pb.rb
index bb93223e..3acb9d26 100644
--- a/lib/gen/temporal/api/workflowservice/v1/service_services_pb.rb
+++ b/lib/gen/temporal/api/workflowservice/v1/service_services_pb.rb
@@ -288,20 +288,29 @@ class Service
             rpc :DeleteSchedule, ::Temporalio::Api::WorkflowService::V1::DeleteScheduleRequest, ::Temporalio::Api::WorkflowService::V1::DeleteScheduleResponse
             # List all schedules in a namespace.
             rpc :ListSchedules, ::Temporalio::Api::WorkflowService::V1::ListSchedulesRequest, ::Temporalio::Api::WorkflowService::V1::ListSchedulesResponse
-            # Allows users to specify a graph of worker build id based versions on a
-            # per task queue basis. Versions are ordered, and may be either compatible
-            # with some extant version, or a new incompatible version.
+            # Allows users to specify sets of worker build id versions on a per task queue basis. Versions
+            # are ordered, and may be either compatible with some extant version, or a new incompatible
+            # version, forming sets of ids which are incompatible with each other, but whose contained
+            # members are compatible with one another.
+            #
             # (-- api-linter: core::0134::response-message-name=disabled
-            #     aip.dev/not-precedent: UpdateWorkerBuildIdOrdering RPC doesn't follow Google API format. --)
+            #     aip.dev/not-precedent: UpdateWorkerBuildIdCompatibility RPC doesn't follow Google API format. --)
             # (-- api-linter: core::0134::method-signature=disabled
-            #     aip.dev/not-precedent: UpdateWorkerBuildIdOrdering RPC doesn't follow Google API format. --)
-            rpc :UpdateWorkerBuildIdOrdering, ::Temporalio::Api::WorkflowService::V1::UpdateWorkerBuildIdOrderingRequest, ::Temporalio::Api::WorkflowService::V1::UpdateWorkerBuildIdOrderingResponse
-            # Fetches the worker build id versioning graph for some task queue.
-            rpc :GetWorkerBuildIdOrdering, ::Temporalio::Api::WorkflowService::V1::GetWorkerBuildIdOrderingRequest, ::Temporalio::Api::WorkflowService::V1::GetWorkerBuildIdOrderingResponse
+            #     aip.dev/not-precedent: UpdateWorkerBuildIdCompatibility RPC doesn't follow Google API format. --)
+            rpc :UpdateWorkerBuildIdCompatibility, ::Temporalio::Api::WorkflowService::V1::UpdateWorkerBuildIdCompatibilityRequest, ::Temporalio::Api::WorkflowService::V1::UpdateWorkerBuildIdCompatibilityResponse
+            # Fetches the worker build id versioning sets for some task queue and related metadata.
+            rpc :GetWorkerBuildIdCompatibility, ::Temporalio::Api::WorkflowService::V1::GetWorkerBuildIdCompatibilityRequest, ::Temporalio::Api::WorkflowService::V1::GetWorkerBuildIdCompatibilityResponse
             # Invokes the specified update function on user workflow code.
             # (-- api-linter: core::0134=disabled
             #     aip.dev/not-precedent: UpdateWorkflowExecution doesn't follow Google API format --)
             rpc :UpdateWorkflowExecution, ::Temporalio::Api::WorkflowService::V1::UpdateWorkflowExecutionRequest, ::Temporalio::Api::WorkflowService::V1::UpdateWorkflowExecutionResponse
+            # Polls a workflow execution for the outcome of a workflow execution update
+            # previously issued through the UpdateWorkflowExecution RPC. The effective
+            # timeout on this call will be shorter of the the caller-supplied gRPC
+            # timeout and the server's configured long-poll timeout.
+            # (-- api-linter: core::0134=disabled
+            #     aip.dev/not-precedent: UpdateWorkflowExecution doesn't follow Google API format --)
+            rpc :PollWorkflowExecutionUpdate, ::Temporalio::Api::WorkflowService::V1::PollWorkflowExecutionUpdateRequest, ::Temporalio::Api::WorkflowService::V1::PollWorkflowExecutionUpdateResponse
             # StartBatchOperation starts a new batch operation
             rpc :StartBatchOperation, ::Temporalio::Api::WorkflowService::V1::StartBatchOperationRequest, ::Temporalio::Api::WorkflowService::V1::StartBatchOperationResponse
             # StopBatchOperation stops a batch operation
diff --git a/lib/temporal/connection/converter/composite.rb b/lib/temporal/connection/converter/composite.rb
index 2b0d2f11..640ae4f7 100644
--- a/lib/temporal/connection/converter/composite.rb
+++ b/lib/temporal/connection/converter/composite.rb
@@ -25,7 +25,7 @@ def from_payload(payload)
           converter = payload_converters_by_encoding[encoding]
 
           if converter.nil?
-            raise ConverterNotFound
+            raise ConverterNotFound, "Could not find PayloadConverter for #{encoding}"
           end
 
           converter.from_payload(payload)
diff --git a/proto b/proto
index 4c2f6a28..ae312b07 160000
--- a/proto
+++ b/proto
@@ -1 +1 @@
-Subproject commit 4c2f6a281fa3fde8b0a24447de3e0d0f47d230b4
+Subproject commit ae312b0724003957b96fb966e3fe25a02abaade4
diff --git a/spec/unit/lib/temporal/connection/converter/composite_spec.rb b/spec/unit/lib/temporal/connection/converter/composite_spec.rb
index fd4bee56..b78a62c0 100644
--- a/spec/unit/lib/temporal/connection/converter/composite_spec.rb
+++ b/spec/unit/lib/temporal/connection/converter/composite_spec.rb
@@ -54,7 +54,11 @@
         metadata: { 'encoding' => 'fake' }
       )
 
-      expect { subject.from_payload(payload) }.to raise_error(Temporal::Connection::Converter::Composite::ConverterNotFound)
+      expect do
+        subject.from_payload(payload)
+      end.to raise_error(Temporal::Connection::Converter::Composite::ConverterNotFound) do |e|
+        expect(e.message).to eq('Could not find PayloadConverter for fake')
+      end
     end
   end
 end