File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -473,6 +473,8 @@ def _prepare_step(
473473 # We are a combiner if a variable in our step's plumbing refers to an input
474474 # whose origin is of type 'files'.
475475
476+ _LOGGER .info ("Preparing step '%s'..." , step_name )
477+
476478 our_job_definition : dict [str , Any ] = self ._get_step_job (step = step_definition )
477479 if not our_job_definition :
478480 return StepPreparationResponse (
@@ -489,6 +491,11 @@ def _prepare_step(
489491 get_step_prior_step_connections (step_definition = step_definition )
490492 )
491493
494+ _LOGGER .debug ("Step '%s' inputs=%s" , step_name , our_inputs )
495+ _LOGGER .debug (
496+ "Step '%s' prior step plumbing=%s" , step_name , plumbing_of_prior_steps
497+ )
498+
492499 we_are_a_combiner : bool = False
493500
494501 # What step might we be combining?
@@ -507,6 +514,8 @@ def _prepare_step(
507514 if step_name_being_combined :
508515 break
509516
517+ _LOGGER .debug ("Step '%s' is combiner (%s)" , step_name , we_are_a_combiner )
518+
510519 # If we are a combiner
511520 # we must make suer that all the step instances we're combining are done.
512521 # If not, we must leave.
You can’t perform that action at this time.
0 commit comments