jeffschoner · jeffschoner · Apr 26, 2025 · Apr 26, 2025 · Apr 26, 2025 · Apr 26, 2025
diff --git a/Gemfile b/Gemfile
@@ -1,5 +1,6 @@
 source 'https://rubygems.org'
 
 gem 'google-protobuf', '~> 3.19'
+gem 'logger'
 
 gemspec
diff --git a/examples/bin/worker b/examples/bin/worker
@@ -54,6 +54,7 @@ worker.register_workflow(MetadataWorkflow)
 worker.register_workflow(ParentCloseWorkflow)
 worker.register_workflow(ParentIdReuseWorkflow)
 worker.register_workflow(ParentWorkflow)
+worker.register_workflow(PriorityWorkflow)
 worker.register_workflow(ProcessFileWorkflow)
 worker.register_workflow(QueryWorkflow)
 worker.register_workflow(QuickTimeoutWorkflow)

diff --git a/examples/spec/integration/priority_workflow_spec.rb b/examples/spec/integration/priority_workflow_spec.rb
@@ -0,0 +1,21 @@
+require 'workflows/priority_workflow'
+
+describe PriorityWorkflow do
+  subject { described_class }
+
+  it 'executes with priority' do
+    workflow_id = SecureRandom.uuid
+    run_id = Temporal.start_workflow(
+      PriorityWorkflow,
+      true,
+      options: { workflow_id: workflow_id, priority_key: 4 },
+    )
+    Temporal.await_workflow_result(
+      PriorityWorkflow,
+      workflow_id: workflow_id,
+      run_id: run_id,
+    )
+    execution_info = Temporal.fetch_workflow_execution_info('ruby-samples', workflow_id, run_id)
+    expect(execution_info.priority_key).to eq(4)
+  end
+end
diff --git a/examples/workflows/priority_workflow.rb b/examples/workflows/priority_workflow.rb
@@ -0,0 +1,7 @@
+require 'activities/hello_world_activity'
+
+class PriorityWorkflow < Temporal::Workflow
+  def execute(important = false)
+    return HelloWorldActivity.execute!('somebody', options: { priority_key: important ? 1 : 5 })
+  end
+end
diff --git a/lib/gen/google/api/annotations_pb.rb b/lib/gen/google/api/annotations_pb.rb
diff --git a/lib/gen/google/api/http_pb.rb b/lib/gen/google/api/http_pb.rb
diff --git a/lib/gen/google/protobuf/any_pb.rb b/lib/gen/google/protobuf/any_pb.rb
diff --git a/lib/gen/google/protobuf/descriptor_pb.rb b/lib/gen/google/protobuf/descriptor_pb.rb
diff --git a/lib/gen/google/protobuf/duration_pb.rb b/lib/gen/google/protobuf/duration_pb.rb
diff --git a/lib/gen/google/protobuf/empty_pb.rb b/lib/gen/google/protobuf/empty_pb.rb
diff --git a/lib/gen/google/protobuf/struct_pb.rb b/lib/gen/google/protobuf/struct_pb.rb
diff --git a/lib/gen/google/protobuf/timestamp_pb.rb b/lib/gen/google/protobuf/timestamp_pb.rb
diff --git a/lib/gen/google/protobuf/wrappers_pb.rb b/lib/gen/google/protobuf/wrappers_pb.rb
diff --git a/lib/gen/temporal/api/activity/v1/message_pb.rb b/lib/gen/temporal/api/activity/v1/message_pb.rb
diff --git a/lib/gen/temporal/api/batch/v1/message_pb.rb b/lib/gen/temporal/api/batch/v1/message_pb.rb