runTheMatrix.TheMatrix Class Reference

Inheritance diagram for runTheMatrix.TheMatrix:

Public Member Functions
def	__init__ (self, opt)
def	complete_predefined (self, text, line, start_idx, end_idx)
def	complete_searchInWorkflow (self, text, line, start_idx, end_idx)
def	complete_showWorkflow (self, text, line, start_idx, end_idx)
def	default (self, inp)
def	do_clear (self, arg)
def	do_dumpWorkflowId (self, arg)
def	do_exit (self, arg)
def	do_predefined (self, arg)
def	do_search (self, arg)
def	do_searchInWorkflow (self, arg)
def	do_showWorkflow (self, arg)
def	help_dumpWorkflowId (self)
def	help_predefined (self)
def	help_search (self)
def	help_searchInWorkflow (self)
def	help_showWorkflow (self)

Public Attributes
	matrices_
	opt_

Static Public Attributes
	do_EOF
	intro
	prompt

Detailed Description

Definition at line 445 of file runTheMatrix.py.

Constructor & Destructor Documentation

__init__()

def runTheMatrix.TheMatrix.__init__	(		self,
			opt
	)

Definition at line 449 of file runTheMatrix.py.

            def __init__(self, opt):
                cmd.Cmd.__init__(self)
                self.opt_ = opt
                self.matrices_ = {}
                tmp = MatrixReader(self.opt_)
                for what in tmp.files:
                    what = what.replace('relval_','')
                    self.opt_.what = what
                    self.matrices_[what] = MatrixReader(self.opt_)
                    self.matrices_[what].prepare(self.opt_.useInput, self.opt_.refRel,
                                                self.opt_.fromScratch)
                os.system("clear")

Member Function Documentation

complete_predefined()

def runTheMatrix.TheMatrix.complete_predefined	(		self,
			text,
			line,
			start_idx,
			end_idx
	)

Definition at line 479 of file runTheMatrix.py.

            def complete_predefined(self, text, line, start_idx, end_idx):
                if text and len(text) > 0:
                    return [t for t in predefinedSet.keys() if t.startswith(text)]
                else:
                    return predefinedSet.keys()

complete_searchInWorkflow()

def runTheMatrix.TheMatrix.complete_searchInWorkflow	(		self,
			text,
			line,
			start_idx,
			end_idx
	)

Definition at line 530 of file runTheMatrix.py.

References relativeConstraints.keys, and runTheMatrix.TheMatrix.matrices_.

            def complete_searchInWorkflow(self, text, line, start_idx, end_idx):
                if text and len(text) > 0:
                    return [t for t in self.matrices_.keys() if t.startswith(text)]
                else:
                    return self.matrices_.keys()

complete_showWorkflow()

def runTheMatrix.TheMatrix.complete_showWorkflow	(		self,
			text,
			line,
			start_idx,
			end_idx
	)

Definition at line 503 of file runTheMatrix.py.

References relativeConstraints.keys, and runTheMatrix.TheMatrix.matrices_.

            def complete_showWorkflow(self, text, line, start_idx, end_idx):
                if text and len(text) > 0:
                    return [t for t in self.matrices_.keys() if t.startswith(text)]
                else:
                    return self.matrices_.keys()

default()

def runTheMatrix.TheMatrix.default	(		self,
			inp
	)

Definition at line 470 of file runTheMatrix.py.

References runTheMatrix.TheMatrix.do_exit().

            def default(self, inp):
                if inp == 'x' or inp == 'q':
                    return self.do_exit(inp)

do_clear()

def runTheMatrix.TheMatrix.do_clear	(		self,
			arg
	)

Clear the screen, put prompt at the top

Definition at line 462 of file runTheMatrix.py.

            def do_clear(self, arg):
                """Clear the screen, put prompt at the top"""
                os.system("clear")

do_dumpWorkflowId()

def runTheMatrix.TheMatrix.do_dumpWorkflowId	(		self,
			arg
	)

Definition at line 576 of file runTheMatrix.py.

References dqmMemoryStats.float, mps_monitormerge.items, runTheMatrix.TheMatrix.matrices_, print(), and str.

            def do_dumpWorkflowId(self, arg):
                wflids = arg.split()
                if len(wflids) == 0:
                    print("dumpWorkflowId [wfl-id1 [...]]")
                    return

                fmt   = "[%d]: %s\n"
                maxLen = 100
                for wflid in wflids:
                    dump = True
                    for key, mrd in self.matrices_.items():
                        for wfl in mrd.workFlows:
                            if wfl.numId == float(wflid):
                                wfName, stepNames = wfl.nameId.split('+',1)
                                if dump:
                                    dump = False
                                    print(wfl.numId, stepNames)
                                    for i,s in enumerate(wfl.cmds):
                                        print(fmt % (i+1, (str(s)+' ')))
                                    print("\nWorkflow found in %s." % key)
                                else:
                                    print("Workflow also found in %s." % key)

do_exit()

def runTheMatrix.TheMatrix.do_exit	(		self,
			arg
	)

Definition at line 466 of file runTheMatrix.py.

References print().

Referenced by runTheMatrix.TheMatrix.default().

            def do_exit(self, arg):
                print("Leaving the Matrix")
                return True

do_predefined()

def runTheMatrix.TheMatrix.do_predefined	(		self,
			arg
	)

Print the list of predefined workflows

Definition at line 485 of file runTheMatrix.py.

References print().

            def do_predefined(self, arg):
                """Print the list of predefined workflows"""
                print("List of predefined workflows")
                if arg:
                    for w in arg.split():
                        if w in predefinedSet.keys():
                            print("Predefined Set: %s" % w)
                            print(predefinedSet[w])
                        else:
                            print("Unknown Set: %s" % w)
                else:
                    print(predefinedSet.keys())

do_search()

def runTheMatrix.TheMatrix.do_search	(		self,
			arg
	)

Definition at line 564 of file runTheMatrix.py.

References runTheMatrix.TheMatrix.do_searchInWorkflow(), join(), relativeConstraints.keys, runTheMatrix.TheMatrix.matrices_, and print().

            def do_search(self, arg):
                args = arg.split()
                if len(args) < 1:
                    print("search regexp")
                    return
                for wfl in self.matrices_.keys():
                    self.do_searchInWorkflow(' '.join([wfl, args[0]]))

do_searchInWorkflow()

def runTheMatrix.TheMatrix.do_searchInWorkflow	(		self,
			arg
	)

Definition at line 536 of file runTheMatrix.py.

References relativeConstraints.keys, runTheMatrix.TheMatrix.matrices_, and print().

Referenced by runTheMatrix.TheMatrix.do_search().

            def do_searchInWorkflow(self, arg):
                args = arg.split()
                if len(args) < 2:
                    print("searchInWorkflow name regexp")
                    return
                if args[0] not in self.matrices_.keys():
                    print("Unknown workflow")
                    return
                import re
                pattern = None
                try:
                    pattern = re.compile(args[1])
                except:
                    print("Failed to compile regexp %s" % args[1])
                    return
                counter = 0
                for wfl in self.matrices_[args[0]].workFlows:
                    wfName, stepNames = wfl.nameId.split('+',1)
                    if re.match(pattern, wfName) or re.match(pattern, stepNames):
                        print("%s %s %s" % (wfl.numId, wfName, stepNames))
                        counter += 1
                print("Found %d compatible workflows inside %s" % (counter, args[0]))

do_showWorkflow()

def runTheMatrix.TheMatrix.do_showWorkflow	(		self,
			arg
	)

Definition at line 509 of file runTheMatrix.py.

References relativeConstraints.keys, runTheMatrix.TheMatrix.matrices_, and print().

            def do_showWorkflow(self, arg):
                if arg == '':
                    print("Available workflows:")
                    for k in self.matrices_.keys():
                        print(k)
                else:
                    selected = arg.split()
                    for k in selected:
                        if k not in self.matrices_.keys():
                            print("Unknown workflow %s: skipping" % k)
                        else:
                            for wfl in self.matrices_[k].workFlows:
                                wfName, stepNames = wfl.nameId.split('+',1)
                                print("%s %s %s" % (wfl.numId, wfName, stepNames))
                            print("%s contains %d workflows" % (k, len(self.matrices_[k].workFlows)))

help_dumpWorkflowId()

def runTheMatrix.TheMatrix.help_dumpWorkflowId

(

self

)

Definition at line 572 of file runTheMatrix.py.

References join(), and print().

            def help_dumpWorkflowId(self):
                print("\n".join(["dumpWorkflowId [wfl-id1 [...]]\n",
                    "Dumps the details (cmsDriver commands for all steps) of the space-separated workflow-ids in input."]))

help_predefined()

def runTheMatrix.TheMatrix.help_predefined

(

self

)

Definition at line 474 of file runTheMatrix.py.

References join(), and print().

            def help_predefined(self):
                print("\n".join(["predefined [predef1 [...]]\n",
                "Run w/o argument, it will print the list of known predefined workflows.",
                "Run with space-separated predefined workflows, it will print the workflow-ids registered to them"]))

help_search()

def runTheMatrix.TheMatrix.help_search

(

self

)

Definition at line 559 of file runTheMatrix.py.

References join(), and print().

            def help_search(self):
                print("\n".join(["search search_regexp\n",
                    "This command will search for a match within all workflows registered.",
                    "The search is done on both the workflow name and the names of steps registered to it."]))

help_searchInWorkflow()

def runTheMatrix.TheMatrix.help_searchInWorkflow

(

self

)

Definition at line 525 of file runTheMatrix.py.

References join(), and print().

            def help_searchInWorkflow(self):
                print("\n".join(["searchInWorkflow wfl_name search_regexp\n",
                    "This command will search for a match within all workflows registered to wfl_name.",
                    "The search is done on both the workflow name and the names of steps registered to it."]))

help_showWorkflow()

def runTheMatrix.TheMatrix.help_showWorkflow

(

self

)

Definition at line 498 of file runTheMatrix.py.

References join(), and print().

            def help_showWorkflow(self):
                print("\n".join(["showWorkflow [workflow1 [...]]\n",
                    "Run w/o arguments, it will print the list of registered macro-workflows.",
                    "Run with space-separated workflows, it will print the full list of workflow-ids registered to them"]))

Member Data Documentation

do_EOF

runTheMatrix.TheMatrix.do_EOF

static

Definition at line 599 of file runTheMatrix.py.

intro

runTheMatrix.TheMatrix.intro

static

Definition at line 446 of file runTheMatrix.py.

matrices_

runTheMatrix.TheMatrix.matrices_

Definition at line 452 of file runTheMatrix.py.

Referenced by runTheMatrix.TheMatrix.complete_searchInWorkflow(), runTheMatrix.TheMatrix.complete_showWorkflow(), runTheMatrix.TheMatrix.do_dumpWorkflowId(), runTheMatrix.TheMatrix.do_search(), runTheMatrix.TheMatrix.do_searchInWorkflow(), and runTheMatrix.TheMatrix.do_showWorkflow().

opt_

runTheMatrix.TheMatrix.opt_

Definition at line 451 of file runTheMatrix.py.

prompt

runTheMatrix.TheMatrix.prompt

static

Definition at line 447 of file runTheMatrix.py.