sample_workflow.rb

Proc.new do |tx|
            NoOpV1(tx)
            branch(tx.aggregates) do |agg|
              label(:InputFormatCheckerAndConverter)
              InputFormatCheckerAndConverter(agg)
              label(:ConvertToImageAndCreateChild)
              ImageConverterAndChildCreator(agg)
              branch(agg.active_children) do |child|
                label(:MarkerStation)
                APIContentV1(child, station_index: 0)
                label(:Highlighter)
                HighlighterAndChildCreator(child)
                branch(child.active_children) do |grand_child|
                  label(:APIContentV1)
                  APIContentV1(grand_child, station_index: 1)
                  label(:LeaseDetailAnalyzer)
                  LeaseDetailAnalyzer(grand_child)
                  branch(grand_child.active_children) do |last_child|
                    label(:APIContentV1)
                    APIContentV1(last_child, station_index: last_child.data['station_index'])
                    label(:complete)
                    UnitAnalytic(last_child)
                  end
                  label(:LabelChecker)
                  LabelChecker(grand_child)
                  branch(grand_child.active_children) do |final_station_child|
                    label(:FinalStation)
                    APIContentV1(final_station_child, station_index: 5)
                    label(:complete)
                    UnitAnalytic(final_station_child)
                  end
                  label(:complete)
                  UnitAnalytic(grand_child)
                end
                label(:complete)
                UnitAnalytic(child)
              end
              label(:complete)
              UnitAnalytic(agg, [2,3,4])
            end
            AutoCompleteV1(tx)
            CallbackV3(tx)
          end