diff --git a/examples/spec/helpers.rb b/examples/spec/helpers.rb index 4d6d9a20..b5f32504 100644 --- a/examples/spec/helpers.rb +++ b/examples/spec/helpers.rb @@ -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 diff --git a/examples/spec/integration/describe_namespace_spec.rb b/examples/spec/integration/describe_namespace_spec.rb index 86501f7b..d042190e 100644 --- a/examples/spec/integration/describe_namespace_spec.rb +++ b/examples/spec/integration/describe_namespace_spec.rb @@ -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 diff --git a/examples/spec/integration/metadata_workflow_spec.rb b/examples/spec/integration/metadata_workflow_spec.rb index ac828e01..508c3af8 100644 --- a/examples/spec/integration/metadata_workflow_spec.rb +++ b/examples/spec/integration/metadata_workflow_spec.rb @@ -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 @@ -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 @@ -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