diff --git a/spec/lib/waterdrop/producer/transactions_spec.rb b/spec/lib/waterdrop/producer/transactions_spec.rb index 1db3833..64bb745 100644 --- a/spec/lib/waterdrop/producer/transactions_spec.rb +++ b/spec/lib/waterdrop/producer/transactions_spec.rb @@ -113,6 +113,8 @@ end context 'when we start transaction and raise an error' do + subject(:producer) { build(:transactional_producer, queue_buffering_max_ms: 5_000) } + it 'expect to re-raise this error' do expect do producer.transaction do