diff --git a/lib/sequel/pgt_outbox.rb b/lib/sequel/pgt_outbox.rb index 20dab34..f6c76dc 100644 --- a/lib/sequel/pgt_outbox.rb +++ b/lib/sequel/pgt_outbox.rb @@ -39,9 +39,9 @@ def depth_guard_clause(depth_limit = nil) depth_limit = depth_limit.to_i raise ArgumentError, ':trigger_depth_limit option must be at least 1' unless depth_limit >= 1 - <<-SQL - IF pg_trigger_depth() > #{depth_limit} THEN - RETURN NEW; + <<~SQL + IF pg_trigger_depth() > #{depth_limit} THEN + RETURN NEW; END IF; SQL end diff --git a/test/sequel/test_pgt_outbox.rb b/test/sequel/test_pgt_outbox.rb index 95cb738..fa42bc4 100755 --- a/test/sequel/test_pgt_outbox.rb +++ b/test/sequel/test_pgt_outbox.rb @@ -15,8 +15,8 @@ class Crass def depth_sql(depth) <<~SQL.strip IF pg_trigger_depth() > #{depth} THEN - RETURN NEW; - END IF; + RETURN NEW; + END IF; SQL end