+    validProcessorIRIs = [ processor[u'processorIRI'] for processor in message[u'processors'] ]

+

+    try:

+        for inputs in (processor[u'inputs'] for processor in message[u'processors']):

+            for inputEnrichment in inputs:

+                if inputEnrichment not in validProcessorIRIs:

+                    return False

+    except Exception as e:

+        log.warning(u'invalid or missing processor inputs list of IRIs; e = %s' % e)

+        return False

+

+    return True

+

+

+def validateInput(message):

+    """

+    Checks that message has the minimum initialized attributes to

+    create a new job, and that none of the automatic definitions are

+    pre-initialized (e.g. jobID).

+    """

+    validated = False

+

+    if message:

+        log.debug(u'validating input message = %s' % message)

+        try:

+            if message[u'encoding'] == u'UTF-8':

+                if message.get(u'completionDate', None):

+                    return False

+                if message[u'payload'].get(u'aggregatedResults', None):

+                    return False

+                if len(message['processors']):

+                    if message['payloadType']:

+                        validated = _validateProcessorsAndInputsIn(message)

+                    else:

+                        log.warning(u'message.payloadType missing or invalid')

+                else:

+                    log.warning(u'message.processors empty or null')

+        except Exception as e:

+            log.warning(u'message format error; e = %s' % e)

+

+    log.debug(u'%svalid input message' % (u'in' if not validated else u''))

+