Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions examples/spec/helpers.rb
Original file line number Diff line number Diff line change
Expand Up @@ -33,4 +33,8 @@ def fetch_history(workflow_id, run_id, options = {})
}.merge(options)
)
end

def integration_spec_namespace
ENV.fetch('TEMPORAL_NAMESPACE', 'ruby-samples')
end
end
15 changes: 9 additions & 6 deletions examples/spec/integration/describe_namespace_spec.rb
Original file line number Diff line number Diff line change
@@ -1,16 +1,19 @@
require 'temporal/errors'

describe 'Temporal.describe_namespace' do
describe 'Temporal.describe_namespace', :integration do
it 'returns a value' do
description = 'Namespace for temporal-ruby integration test'
namespace = integration_spec_namespace
rescued = false
begin
Temporal.register_namespace('a_test_namespace', description)
Temporal.register_namespace(namespace)
rescue Temporal::NamespaceAlreadyExistsFailure
rescued = true
end
result = Temporal.describe_namespace('a_test_namespace')
expect(rescued).to eq(true)
result = Temporal.describe_namespace(namespace)
expect(result).to be_an_instance_of(Temporal::Api::WorkflowService::V1::DescribeNamespaceResponse)
expect(result.namespace_info.name).to eq('a_test_namespace')
expect(result.namespace_info.name).to eq(namespace)
expect(result.namespace_info.state).to eq(:NAMESPACE_STATE_REGISTERED)
expect(result.namespace_info.description).to eq(description)
expect(result.namespace_info.description).to_not eq(nil)
end
end
6 changes: 3 additions & 3 deletions examples/spec/integration/metadata_workflow_spec.rb
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
require 'workflows/metadata_workflow'

describe MetadataWorkflow do
describe MetadataWorkflow, :integration do
subject { described_class }

it 'gets task queue from running workflow' do
Expand Down Expand Up @@ -66,7 +66,7 @@
expect(actual_result.memo['foo']).to eq('bar')

expect(Temporal.fetch_workflow_execution_info(
'ruby-samples', workflow_id, nil
integration_spec_namespace, workflow_id, nil
).memo).to eq({ 'foo' => 'bar' })
end

Expand All @@ -85,7 +85,7 @@
)
expect(actual_result.memo).to eq({})
expect(Temporal.fetch_workflow_execution_info(
'ruby-samples', workflow_id, nil
integration_spec_namespace, workflow_id, nil
).memo).to eq({})
end
end