From dd5cbd67bbf6fd9b8664373bb79cefccaaa53ba6 Mon Sep 17 00:00:00 2001 From: cdimitroulas Date: Mon, 26 Sep 2022 17:17:16 +0100 Subject: [PATCH] Fixed Temporal::Connection::GRPC#describe_task_queue method --- lib/temporal/connection/grpc.rb | 2 +- spec/unit/lib/temporal/grpc_spec.rb | 21 +++++++++++++++++++++ 2 files changed, 22 insertions(+), 1 deletion(-) diff --git a/lib/temporal/connection/grpc.rb b/lib/temporal/connection/grpc.rb index 91bb3774..2074ad11 100644 --- a/lib/temporal/connection/grpc.rb +++ b/lib/temporal/connection/grpc.rb @@ -530,7 +530,7 @@ def describe_task_queue(namespace:, task_queue:) task_queue: Temporal::Api::TaskQueue::V1::TaskQueue.new( name: task_queue ), - task_queue_type: Temporal::Api::Enums::V1::TaskQueueType::Workflow, + task_queue_type: Temporal::Api::Enums::V1::TaskQueueType::TASK_QUEUE_TYPE_WORKFLOW, include_task_queue_status: true ) client.describe_task_queue(request) diff --git a/spec/unit/lib/temporal/grpc_spec.rb b/spec/unit/lib/temporal/grpc_spec.rb index fecb25e4..946ffc76 100644 --- a/spec/unit/lib/temporal/grpc_spec.rb +++ b/spec/unit/lib/temporal/grpc_spec.rb @@ -620,4 +620,25 @@ class TestDeserializer end end end + + describe "#describe_task_queue" do + let(:response) do + Temporal::Api::WorkflowService::V1::DescribeTaskQueueResponse.new + end + + before { allow(grpc_stub).to receive(:describe_task_queue).and_return(response) } + + it 'calls GRPC service with supplied arguments' do + subject.describe_task_queue( + namespace: 'test ns', + task_queue: 'test task_queue', + ) + + expect(grpc_stub).to have_received(:describe_task_queue) do |request| + expect(request).to be_an_instance_of(Temporal::Api::WorkflowService::V1::DescribeTaskQueueRequest) + expect(request.namespace).to eq('test ns') + expect(request.task_queue.name).to eq('test task_queue') + end + end + end end