Dag for debugging digdag ruby operator

myruby.dig

_export:
  rb:
    require: myruby
+step1:
  rb>: Task::MyWorkflow.step1

myruby.rb

module Task
    class MyWorkflow

        def step1
            Digdag.env.add_subtask(
                {
                    "+step2_1": {
                        "rb>": "Task::MyWorkflow.step2",
                    },
                    "+step2_2": {
                        "rb>": "Task::MyWorkflow.step2",
                    },
                    "_parallel": true
                }
            )
            Digdag.env.add_subtask(
                {
                    "+step3_1": {
                        "rb>": "Task::MyWorkflow.step3",
                    },
                    "+step3_2": {
                        "rb>": "Task::MyWorkflow.step3",
                    },
                    "_parallel": true
                }
            )
        end

        def step2
            sleep 3
            raise if [true, false].sample
        end

        def step3
            sleep 1
            raise if [true, false].sample
            Digdag.env.add_subtask(
                {
                    "+step4": {
                        "rb>": "Task::MyWorkflow.step4",
                    },
                }
            )
        end
        
        def step4
            sleep 1
            raise if [true, false].sample
        end
    end
end