Show dependencies in execution plan details

Author: adamruzicka

lib/dynflow/persistence.rb

@@ -97,6 +97,14 @@ def find_old_execution_plans(age)
       end
     end
 
+    def find_execution_plan_dependencies(execution_plan_id)
+      adapter.find_execution_plan_dependencies(execution_plan_id)
+    end
+
+    def find_blocked_execution_plans(execution_plan_id)
+      adapter.find_blocked_execution_plans(execution_plan_id)
+    end
+
     def find_ready_delayed_plans(time)
       adapter.find_ready_delayed_plans(time).map do |plan|
         DelayedPlan.new_from_hash(@world, plan)

lib/dynflow/persistence_adapters/abstract.rb

@@ -68,6 +68,14 @@ def save_execution_plan(execution_plan_id, value)
         raise NotImplementedError
       end
 
+      def find_execution_plan_dependencies(execution_plan_id)
+        raise NotImplementedError
+      end
+
+      def find_blocked_execution_plans(execution_plan_id)
+        raise NotImplementedError
+      end
+
       def find_ready_delayed_plans(options = {})
         raise NotImplementedError
       end

lib/dynflow/persistence_adapters/sequel.rb

@@ -140,13 +140,25 @@ def find_old_execution_plans(age)
           .all.map { |plan| execution_plan_column_map(load_data plan, table_name) }
       end
 
+      def find_execution_plan_dependencies(execution_plan_id)
+        table(:execution_plan_dependency)
+          .where(execution_plan_uuid: execution_plan_id)
+          .select_map(:blocked_by_uuid)
+      end
+
+      def find_blocked_execution_plans(execution_plan_id)
+        table(:execution_plan_dependency)
+          .where(blocked_by_uuid: execution_plan_id)
+          .select_map(:execution_plan_uuid)
+      end
+
       def find_ready_delayed_plans(time)
         table_name = :delayed
         # Subquery to find delayed plans that have at least one non-stopped dependency
         plans_with_unfinished_deps = table(:execution_plan_dependency)
-          .join(TABLES[:execution_plan], uuid: :blocked_by_uuid)
-          .where(::Sequel.~(state: 'stopped'))
-          .select(:execution_plan_uuid)
+                                     .join(TABLES[:execution_plan], uuid: :blocked_by_uuid)
+                                     .where(::Sequel.~(state: 'stopped'))
+                                     .select(:execution_plan_uuid)
 
         table(table_name)
           .where(::Sequel.lit('start_at IS NULL OR (start_at <= ? OR (start_before IS NOT NULL AND start_before <= ?))', time, time))

web/views/show.erb

@@ -43,6 +43,32 @@
   <%= h(@plan.ended_at) %>
 </p>
 
+<% if @plan.state == :scheduled && @plan.delay_record %>
+  <% dependencies = @plan.world.persistence.find_execution_plan_dependencies(@plan.id) %>
+  <% if dependencies.any? %>
+    <p>
+      <b>Waiting for execution plans:</b>
+      <ul>
+      <% dependencies.each do |dep_id| %>
+        <li><a href="<%= url("/#{dep_id}") %>"><%= h(dep_id) %></a></li>
+      <% end %>
+      </ul>
+    </p>
+  <% end %>
+<% end %>
+
+<% blocked_plans = @plan.world.persistence.find_blocked_execution_plans(@plan.id) %>
+  <% if blocked_plans.any? %>
+    <p>
+      <b>Blocks execution plans:</b>
+      <ul>
+      <% blocked_plans.each do |dep_id| %>
+        <li><a href="<%= url("/#{dep_id}") %>"><%= h(dep_id) %></a></li>
+      <% end %>
+      </ul>
+    </p>
+  <% end %>
+
 <ul class="phases nav nav-tabs" id="myTab">
   <li><a href="#plan">Plan</a></li>
   <li class="active"><a href="#run">Run</a></li>