Changeset 32902 for trunk/ippdor/src
- Timestamp:
- Dec 8, 2011, 11:47:19 AM (15 years ago)
- Location:
- trunk/ippdor/src/executables
- Files:
-
- 7 edited
-
generate_cam_jobs.py (modified) (2 diffs)
-
generate_chip_jobs.py (modified) (2 diffs)
-
generate_exposure_dag.py (modified) (3 diffs)
-
generate_fake_jobs.py (modified) (2 diffs)
-
generate_stack_jobs.py (modified) (2 diffs)
-
generate_warp_jobs.py (modified) (2 diffs)
-
ippdor_chip_to_warp.py (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
trunk/ippdor/src/executables/generate_cam_jobs.py
r32874 r32902 4 4 Generates the complete Camera stage DAG for one exposure 5 5 """ 6 import sys 6 7 from ipp.CamManager import CamManager as CamManager 7 8 import sys9 import os10 8 11 9 ################################################################# … … 23 21 else: 24 22 RECIPIENT = 'schastel@ifa.hawaii.edu' 25 if os.getenv('USER') == 'ippdor': 26 CAMQUERIER = CamManager(LABEL, EXPOSURE_NAME, recipient=RECIPIENT) 27 else: 28 CAMQUERIER = CamManager(LABEL, EXPOSURE_NAME, recipient=RECIPIENT, 29 host='ipp0012.ifa.hawaii.edu') 23 CAMQUERIER = CamManager(LABEL, EXPOSURE_NAME, recipient=RECIPIENT) 30 24 if STAGE == 'B010': 31 25 CAMQUERIER.build_new_camera_jobs() -
trunk/ippdor/src/executables/generate_chip_jobs.py
r32874 r32902 4 4 Generates the full chip DAG for one exposure 5 5 """ 6 import sys 6 7 from ipp.ChipManager import ChipManager as ChipManager 7 8 from ipp.exceptions.IppException import IppException 8 9 import sys10 import os11 9 12 10 ################################################################# … … 26 24 else: 27 25 RECIPIENT = 'schastel@ifa.hawaii.edu' 28 if os.getenv('USER') == 'ippdor': 29 CHIP_MANAGER = ChipManager(LABEL, EXPOSURE_NAME, 30 RECIPIENT) 31 else: 32 CHIP_MANAGER = ChipManager(LABEL, EXPOSURE_NAME, 33 RECIPIENT, 34 host='ipp0012.ifa.hawaii.edu') 26 CHIP_MANAGER = ChipManager(LABEL, EXPOSURE_NAME, 27 RECIPIENT) 35 28 try: 36 29 if STAGE == 'A010': -
trunk/ippdor/src/executables/generate_exposure_dag.py
r32874 r32902 4 4 Generate the complete DAG for ONE exposure from chip to warp 5 5 """ 6 import sys 6 7 from ipp.helpers import mkdir 7 8 from ipp.ChipManager import ChipManager as ChipManager … … 10 11 from ipp.WarpManager import WarpManager as WarpManager 11 12 from ipp.constants.Globals import Globals as GlobalConstants 12 13 import sys14 import os15 13 16 14 class DagGenerator(ChipManager, CamManager, FakeManager, WarpManager): … … 212 210 RECIPIENT = sys.argv[2] 213 211 EXPOSURE_NAME = sys.argv[3] 214 if os.getenv('USER') == 'ippdor': 215 GENERATOR = DagGenerator(LABEL, EXPOSURE_NAME, RECIPIENT) 216 else: 217 GENERATOR = DagGenerator(LABEL, EXPOSURE_NAME, RECIPIENT, 218 host='ipp0012.ifa.hawaii.edu') 212 GENERATOR = DagGenerator(LABEL, EXPOSURE_NAME, RECIPIENT) 219 213 DAG_NAME = GENERATOR.build_dag() 220 214 GENERATOR.build_new_chips_jobs() -
trunk/ippdor/src/executables/generate_fake_jobs.py
r32874 r32902 4 4 Generates the fake DAG and Condor jobs for one exposure 5 5 """ 6 import sys 6 7 from ipp.FakeManager import FakeManager as FakeManager 7 8 import sys9 import os10 8 11 9 ################################################################# … … 23 21 else: 24 22 RECIPIENT = 'schastel@ifa.hawaii.edu' 25 if os.getenv('USER') == 'ippdor': 26 FAKE_MANAGER = FakeManager(LABEL, EXPOSURE_NAME, 27 recipient=RECIPIENT) 28 else: 29 FAKE_MANAGER = FakeManager(LABEL, EXPOSURE_NAME, 30 recipient=RECIPIENT, 31 host='ipp0012.ifa.hawaii.edu') 23 FAKE_MANAGER = FakeManager(LABEL, EXPOSURE_NAME, RECIPIENT) 32 24 if STAGE == 'C010': 33 25 FAKE_MANAGER.build_new_fake_jobs() -
trunk/ippdor/src/executables/generate_stack_jobs.py
r32874 r32902 4 4 Generates the complete stack stage DAG for one label 5 5 """ 6 import sys 6 7 from ipp.StackManager import StackManager as StackManager 7 8 import sys9 import os10 8 11 9 ################################################################# … … 19 17 LABEL = sys.argv[2] 20 18 RECIPIENT = sys.argv[3] 21 if os.getenv('USER') == 'ippdor': 22 STACK_QUERIER = StackManager(LABEL, RECIPIENT) 23 else: 24 STACK_QUERIER = StackManager(LABEL, 25 RECIPIENT, 26 host='ipp0012.ifa.hawaii.edu') 19 STACK_QUERIER = StackManager(LABEL, RECIPIENT) 27 20 if STAGE == 'E010': 28 21 STACK_QUERIER.build_create_stack_entries_job() -
trunk/ippdor/src/executables/generate_warp_jobs.py
r32874 r32902 4 4 Generates the complete warp stage DAG for one exposure 5 5 """ 6 import sys 6 7 from ipp.WarpManager import WarpManager as WarpManager 7 8 import sys9 import os10 8 11 9 ################################################################# … … 23 21 else: 24 22 RECIPIENT = 'schastel@ifa.hawaii.edu' 25 if os.getenv('USER') == 'ippdor': 26 WARP_QUERIER = WarpManager(LABEL, EXPOSURE_NAME, 27 recipient=RECIPIENT) 28 else: 29 WARP_QUERIER = WarpManager(LABEL, EXPOSURE_NAME, 30 recipient=RECIPIENT, 31 host='ipp0012.ifa.hawaii.edu') 23 WARP_QUERIER = WarpManager(LABEL, EXPOSURE_NAME, RECIPIENT) 32 24 if STAGE == 'D010': 33 25 WARP_QUERIER.build_new_exp_warp_jobs() -
trunk/ippdor/src/executables/ippdor_chip_to_warp.py
r32900 r32902 228 228 sys.exit(4) 229 229 BUILDER = ChipWarpBuilder(LABEL, RECIPIENT) 230 # Check exposures 230 # Check exposures 231 231 EXPOSURES_IDS = dict() 232 232 for _exposure_name in EXPOSURES_NAMES:
Note:
See TracChangeset
for help on using the changeset viewer.
