Sha256: cddcdb530daf2ab9a6c48c78a3016dc9c5927f3f9ee3a8a067ae63e85350f6b2

Contents?: true

Size: 567 Bytes

Versions: 49

Compression:

Stored size: 567 Bytes

Contents

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

49 entries across 49 versions & 1 rubygems

Version Path
dynflow-1.3.0 lib/dynflow/middleware/common/transaction.rb
dynflow-1.2.3 lib/dynflow/middleware/common/transaction.rb
dynflow-1.2.2 lib/dynflow/middleware/common/transaction.rb
dynflow-1.2.1 lib/dynflow/middleware/common/transaction.rb
dynflow-1.2.0 lib/dynflow/middleware/common/transaction.rb
dynflow-1.2.0.pre1 lib/dynflow/middleware/common/transaction.rb
dynflow-1.1.6 lib/dynflow/middleware/common/transaction.rb
dynflow-1.1.5 lib/dynflow/middleware/common/transaction.rb
dynflow-1.1.4 lib/dynflow/middleware/common/transaction.rb
dynflow-1.1.3 lib/dynflow/middleware/common/transaction.rb
dynflow-1.1.2 lib/dynflow/middleware/common/transaction.rb
dynflow-1.1.1 lib/dynflow/middleware/common/transaction.rb
dynflow-1.1.0 lib/dynflow/middleware/common/transaction.rb
dynflow-1.0.5 lib/dynflow/middleware/common/transaction.rb
dynflow-1.0.4 lib/dynflow/middleware/common/transaction.rb
dynflow-1.0.3 lib/dynflow/middleware/common/transaction.rb
dynflow-1.0.2 lib/dynflow/middleware/common/transaction.rb
dynflow-1.0.1 lib/dynflow/middleware/common/transaction.rb
dynflow-1.0.0 lib/dynflow/middleware/common/transaction.rb
dynflow-0.8.37 lib/dynflow/middleware/common/transaction.rb