Source Code for Package bigjob

 1  import os 
 2  import logging 
 3  logging.basicConfig(level=logging.DEBUG, datefmt='%m/%d/%Y %I:%M:%S %p', 
 4                     format='%(asctime)s - %(name)s - %(levelname)s - %(message)s') 
 5  logger = logging.getLogger(name='bigjob') 
 6   
 7   
 8   
 9  version = "latest" 
10   
11  try: 
12      fn = os.path.join(os.path.dirname(os.path.abspath(__file__)), "..", 'VERSION') 
13      version = open(fn).read().strip() 
14      logger.debug("Loading BigJob version: " + version) 
15  except IOError: 
16      pass 
17   
18  #READ config 
19  import ConfigParser 
20  CONFIG_FILE="bigjob.conf" 
21  conf_file = os.path.dirname(os.path.abspath( __file__ )) + "/../" + CONFIG_FILE 
22  config = ConfigParser.ConfigParser() 
23  logger.debug ("read configfile: " + conf_file) 
24  config.read(conf_file) 
25  default_dict = config.defaults()         
26  saga = default_dict["saga"] 
27   
28  if saga.lower() == "bliss": 
29      SAGA_BLISS=True 
30  else: 
31      SAGA_BLISS=False  
32   
33   
34  # define external-facing API 
35  from bigjob.bigjob_manager import bigjob as myBigjob 
36  from bigjob.bigjob_manager import subjob as mySubjob 
37  from bigjob.bigjob_manager import description as myDescription 
38   
39 -class subjob(mySubjob): 
40      pass 
41   
42   
43 -class bigjob(myBigjob): 
44      pass 
45   
46   
47 -class description(myDescription): 
48      pass 
49   
50  #    def __init__(self): 
51  #        self.executable = "" 
52  #        self.number_of_processes = "" 
53  #        self.spmd_variation = "" 
54  #        self.arguments = [] 
55  #        self.working_directory = "" 
56  #        self.output = "" 
57  #        self.error = "" 
58  #        self.filetransfer = [] 
59  #         
60  #         
61  #    def attribute_exists(self, attribute): 
62  #        if self.__dict__.has_key(attribute): 
63  #            return True 
64  #        else: 
65  #            return False 
66  #         
67  #     
68  #    def list_attributes(self): 
69  #        return self.__dict__ 
70  #     
71  #     
72  #    def attribute_is_vector(self, attribute): 
73  #        return isinstance(attribute, list) 
74  #     
75  #     
76  #    def get_attribute(self, attribute): 
77  #        if self.__dict__.has_key(attribute): 
78  #            return self.__dict__[attribute] 
79  #        return None 
80  # 
81