LSSTApplications  11.0-13-gbb96280,12.1.rc1,12.1.rc1+1,12.1.rc1+2,12.1.rc1+5,12.1.rc1+8,12.1.rc1-1-g06d7636+1,12.1.rc1-1-g253890b+5,12.1.rc1-1-g3d31b68+7,12.1.rc1-1-g3db6b75+1,12.1.rc1-1-g5c1385a+3,12.1.rc1-1-g83b2247,12.1.rc1-1-g90cb4cf+6,12.1.rc1-1-g91da24b+3,12.1.rc1-2-g3521f8a,12.1.rc1-2-g39433dd+4,12.1.rc1-2-g486411b+2,12.1.rc1-2-g4c2be76,12.1.rc1-2-gc9c0491,12.1.rc1-2-gda2cd4f+6,12.1.rc1-3-g3391c73+2,12.1.rc1-3-g8c1bd6c+1,12.1.rc1-3-gcf4b6cb+2,12.1.rc1-4-g057223e+1,12.1.rc1-4-g19ed13b+2,12.1.rc1-4-g30492a7
LSSTDataManagementBasePackage
TaskConfig.py
Go to the documentation of this file.
1 import sys
2 import lsst.pex.config as pexConfig
3 import PipelineDefinitionConfig as pipe
4 import FakeTypeMap as fake
5 
6 ## script template
7 class ScriptTemplateConfig(pexConfig.Config):
8  ## input file
9  inputFile = pexConfig.Field("input file", str)
10  ## key value pars to substitute for the template
11  keywords = pexConfig.DictField("key value pairs",keytype=str, itemtype=str, default=dict())
12  ## output file for results of template substitution
13  outputFile = pexConfig.Field("output file", str)
14 
15 
16 ## job template
17 class JobTemplateConfig(pexConfig.Config):
18  ## job script template configuration
19  script = pexConfig.ConfigField("job script", ScriptTemplateConfig)
20  ## condor template configuration
21  condor = pexConfig.ConfigField("template", ScriptTemplateConfig)
22 
23 ## script
24 class ScriptConfig(pexConfig.Config):
25  ## job script template
26  script = pexConfig.ConfigField("job script", ScriptTemplateConfig)
27 
28 ## DAG generation script
29 class DagGeneratorConfig(pexConfig.Config):
30  ## DAG name
31  dagName = pexConfig.Field("dag name", str)
32  ## script name
33  script = pexConfig.Field("script", str)
34  ## input file
35  input = pexConfig.Field("input", str)
36  ## number of ids per job given to execute
37  idsPerJob = pexConfig.Field("the number of ids that will be handled per job", int)
38 
39 ## task
40 class TaskConfig(pexConfig.Config):
41  ## script directory
42  scriptDir = pexConfig.Field("script directory",str)
43  ## pre script (run before any jobs)
44  preScript = pexConfig.ConfigField("pre script", ScriptConfig)
45  ## pre job script (run before each job)
46  preJob = pexConfig.ConfigField("pre job", JobTemplateConfig)
47  ## post job script (run after each job)
48  postJob = pexConfig.ConfigField("post job", JobTemplateConfig)
49  ## worker job configuration
50  workerJob = pexConfig.ConfigField("worker job", JobTemplateConfig)
51  ## DAG generator script to use to create DAG submission file
52  dagGenerator = pexConfig.ConfigField("dagGenerator", DagGeneratorConfig)