<s> from __future__ import print_function <EOL> import inspect <EOL> from inspect import currentframe , getframeinfo <EOL> import errors <EOL> from errors import * <EOL> import os <EOL> import sys <EOL> class pipelineErrors : <EOL> def __init__ ( self ) : <EOL> self . errors = errors ( ) <EOL> self . text = [ ] <EOL> self . errorCode = '<STR_LIT>' <EOL> def noConfigurationType ( self , name ) : <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidConfigurationType ( self , name , configurationType ) : <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' + configurationType + '<STR_LIT>' + name + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidTool ( self , tool ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + '<STR_LIT>' + tool + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def repeatedTaskName ( self , pipeline , task ) : <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT:.>' ) <EOL> self . text . append ( '<STR_LIT>' + '<STR_LIT>' + task + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def repeatedLongFormArgument ( self , nodeId , longFormArgument ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + nodeId + '<STR_LIT>' + '<STR_LIT>' + longFormArgument + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def repeatedShortFormArgument ( self , nodeId , longFormArgument , shortFormArgument ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + nodeId + '<STR_LIT>' + '<STR_LIT>' + shortFormArgument + '<STR_LIT>' + longFormArgument + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def noShortFormArgument ( self , nodeId , longFormArgument ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + nodeId + '<STR_LIT>' + '<STR_LIT>' + longFormArgument + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def noLongFormArgument ( self , nodeId , shortFormArgument ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + nodeId + '<STR_LIT>' + '<STR_LIT>' + shortFormArgument + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def conflictWithGknoArguments ( self , longFormArgument , shortFormArgument , isLongForm ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> if isLongForm : <EOL> self . text . append ( '<STR_LIT>' + longFormArgument + '<STR_LIT>' + '<STR_LIT>' ) <EOL> else : <EOL> self . text . append ( '<STR_LIT>' + longFormArgument + '<STR_LIT>' + shortFormArgument + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def nodeIdIsTaskID ( self , name , node , id ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' + node + '<STR_LIT>' + '<STR_LIT>' + id + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidGreedyArgument ( self , name , task , tool , argument ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + tool + '<STR_LIT>' + argument + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def greedySingleValueArgument ( self , name , task , tool , argument ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + tool + '<STR_LIT>' + argument + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def terminateConsolidateError ( self , name , task ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidStreamSet ( self , pipeline , task , name , validSets , isInput ) : <EOL> text = '<STR_LIT:input>' if isInput else '<STR_LIT>' <EOL> self . text . append ( '<STR_LIT>' + text + '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + text + '<STR_LIT>' + name + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT:\t>' ) <EOL> for setName in validSets : self . text . append ( '<STR_LIT:\t>' + setName ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidNodeInTermination ( self , name , nodeId , text ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + name + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' + text + '<STR_LIT>' + nodeId + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidNodeInArgument ( self , pipeline , argument , address , category ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT>' + category + '<STR_LIT>' + '<STR_LIT>' + argument + '<STR_LIT>' + address + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def repeatedLongFormArgument ( self , helpInfo ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + helpInfo [ <NUM_LIT:0> ] + '<STR_LIT>' + helpInfo [ <NUM_LIT:1> ] + '<STR_LIT>' + helpInfo [ <NUM_LIT:2> ] + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def repeatedShortFormArgument ( self , helpInfo ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + helpInfo [ <NUM_LIT:0> ] + '<STR_LIT>' + helpInfo [ <NUM_LIT:1> ] + '<STR_LIT>' + helpInfo [ <NUM_LIT:2> ] + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def argumentIsTask ( self , longFormArgument , shortFormArgument , isLongForm ) : <EOL> text = '<STR_LIT>' if isLongForm else '<STR_LIT>' <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' + longFormArgument + '<STR_LIT>' + shortFormArgument + '<STR_LIT>' + text + '<STR_LIT:U+0020>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def missingNodeIdForPipelineTask ( self , pipeline , nodeType , nodeId , task ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT>' + nodeId + '<STR_LIT>' + nodeType + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidNodeForExternalPipeline ( self , pipeline , nodeType , nodeId , task , externalPipeline , externalNodeId ) : <EOL> if not externalPipeline : externalPipeline = '<STR_LIT>' <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT>' + nodeId + '<STR_LIT>' + nodeType + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + externalPipeline + '<STR_LIT>' + externalNodeId + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def externalNodeForTask ( self , pipeline , nodeType , nodeId , task , externalNodeId ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT>' + nodeId + '<STR_LIT>' + nodeType + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidTaskInNode ( self , pipeline , nodeType , nodeId , task ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT>' + nodeId + '<STR_LIT>' + nodeType + '<STR_LIT>' + task + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidToolArgument ( self , pipeline , nodeType , nodeId , task , tool , argument ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + pipeline + '<STR_LIT>' + nodeId + '<STR_LIT>' + nodeType + '<STR_LIT>' + task + '<STR_LIT>' + tool + '<STR_LIT>' + '<STR_LIT>' + argument + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def repeatedNodeId ( self , helpInfo ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + helpInfo [ <NUM_LIT:0> ] + '<STR_LIT>' + helpInfo [ <NUM_LIT:1> ] + '<STR_LIT>' + '<STR_LIT>' + helpInfo [ <NUM_LIT:2> ] + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def nodeIdIsTaskId ( self , nodeType , helpInfo ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + helpInfo [ <NUM_LIT:1> ] + '<STR_LIT>' + helpInfo [ <NUM_LIT:0> ] + '<STR_LIT>' + helpInfo [ <NUM_LIT:2> ] + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def invalidNodeConnection ( self , source , target , text ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + source + '<STR_LIT>' + target + '<STR_LIT>' + text + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def noOutputStreamArgument ( self , task , tool ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + task + '<STR_LIT>' + tool + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def noStreamInstructions ( self , task , tool , inputTask , inputTool ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + task + '<STR_LIT>' + tool + '<STR_LIT>' + '<STR_LIT>' + inputTask + '<STR_LIT>' + inputTool + '<STR_LIT>' + '<STR_LIT>' + inputTask + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) <EOL> def noNodeAcceptingStream ( self , task , tool ) : <EOL> self . text . append ( '<STR_LIT>' ) <EOL> self . text . append ( '<STR_LIT>' + task + '<STR_LIT>' + tool + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' + '<STR_LIT>' ) <EOL> self . errors . writeFormattedText ( self . text , errorType = '<STR_LIT:error>' ) <EOL> self . errors . terminate ( self . errorCode ) </s>
