Sha256: 4c56edf565603b2fb0a804c11eb098df99166645e1468acd2bb242298a659fe4

Contents?: true

Size: 597 Bytes

Versions: 25

Compression:

Stored size: 597 Bytes

Contents

# frozen_string_literal: true
module Dynflow
  module Middleware::Common
    class Transaction < Middleware
      def plan_phase(execution_plan)
        rollback_on_error(execution_plan)
      end

      def finalize_phase(execution_plan)
        rollback_on_error(execution_plan)
      end

      private

      def rollback_on_error(execution_plan)
        execution_plan.world.transaction_adapter.transaction do
          pass(execution_plan)
          if execution_plan.error?
            execution_plan.world.transaction_adapter.rollback
          end
        end
      end
    end
  end
end

Version data entries

25 entries across 25 versions & 1 rubygems

Version Path
dynflow-1.8.2 lib/dynflow/middleware/common/transaction.rb
dynflow-1.8.1 lib/dynflow/middleware/common/transaction.rb
dynflow-1.8.0 lib/dynflow/middleware/common/transaction.rb
dynflow-1.7.0 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.11 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.10 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.8 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.7 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.6 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.5 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.4 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.3 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.2 lib/dynflow/middleware/common/transaction.rb
dynflow-1.6.1 lib/dynflow/middleware/common/transaction.rb
dynflow-1.4.9 lib/dynflow/middleware/common/transaction.rb
dynflow-1.4.8 lib/dynflow/middleware/common/transaction.rb
dynflow-1.5.0 lib/dynflow/middleware/common/transaction.rb
dynflow-1.4.7 lib/dynflow/middleware/common/transaction.rb
dynflow-1.4.6 lib/dynflow/middleware/common/transaction.rb
dynflow-1.4.5 lib/dynflow/middleware/common/transaction.rb