def propagate_check_resource(cnxt, rpc_client, next_res_id, current_traversal, predecessors, sender_key, sender_data, is_update, adopt_stack_data):
 def do_check(entity_id, data):
  rpc_client.check_resource(cnxt, entity_id, current_traversal, data, is_update, adopt_stack_data)
 sync_point.sync(cnxt, next_res_id, current_traversal, is_update, do_check, predecessors, {sender_key: sender_data})

def propagate_check_resource ( cnxt , rpc_client , next_res_id , current_traversal , predecessors , sender_key , sender_data , is_update , adopt_stack_data ) : def do_check ( entity_id , data ) : rpc_client . check_resource ( cnxt , entity_id , current_traversal , data , is_update , adopt_stack_data ) sync_point . sync ( cnxt , next_res_id , current_traversal , is_update , do_check , predecessors , { sender_key : sender_data } )
trigger processing of node if all of its dependencies are satisfied .