Flow add "requires" is not validating the full name

[Michael Johnson]

I have a linear flow that adds the following task:

        update_listener_flow.add(amphora_driver_tasks.ListenersUpdate(
            requires=[constants.LOADBALANCER, constants.LISTENERS]))

Where constants.LISTENERS = 'listeners'

The task is defined as:

class ListenersUpdate(BaseAmphoraTask):
    def execute(self, loadbalancer, listeners):

The storage for the flow at load time is:

store={constants.LISTENER:listener, constants.VIP: vip,constants. LOADBALANCER: load_balancer, constants.UPDATE_DICT:listener_updates})

Where constants.LISTENER = 'listener'

No other tasks provide constants.LISTENERS in the flow, but the flow loads and runs without error.

I would expect the flow load and/or run should throw an exception stating that a required parameter "listeners" is not present.

[Michael Johnson (johnsom)]

Darn, the error was masked. This is working as it should.