Changeset 937 for trunk/Monitoring/smon/repo_io.py

Timestamp:

08/23/13 10:13:15 (11 years ago)

Author:

jripsl

Message:

Create AMQP queue on supervisor side if not exists already.

File:

• trunk/Monitoring/smon/repo_io.py (modified) (4 diffs)

trunk/Monitoring/smon/repo_io.py

@@ -20 +20 @@
 
 # line below is to include Prodiguer database I/O library in the search path
-sys.path.append("/home/jripsl/snapshot/src/prodiguer_shared/src")
+sys.path.append("/opt/supervisor/prodiguer_lib/src")
 
 
@@ -33 +33 @@
 
 
-# HACK
-import prodiguer_shared.repo.session as repo_session
-import prodiguer_shared.models as models
-
-
-# Test constants.
-_SIM_ACTIVITY = 'IPSL'
-_SIM_COMPUTE_NODE = 'TGCC'
-_SIM_COMPUTE_NODE_LOGIN = 'p86denv'
-_SIM_COMPUTE_NODE_MACHINE = 'TGCC - Curie'
-_SIM_EXECUTION_START_DATE = datetime.datetime.now()
-_SIM_EXECUTION_STATE = models.EXECUTION_STATE_RUNNING
-_SIM_EXPERIMENT = '1pctCO2'
-_SIM_MODEL_ENGINE = 'IPSL-CM5A-LR'
-_SIM_SPACE = models.SIMULATION_SPACE_TEST
-_MSG_TYPE = "0000"
-_MSG_CONTENT1 = "12345690"
-_MSG_CONTENT2 = "12345690"
 
 
@@ -59 +41 @@
 
 # set mode
-mode=CSTE_MODE_REMOTE_REPO
-#mode=CSTE_MODE_LOCAL_REPO
-
-# set repository driver
+#mode=CSTE_MODE_REMOTE_REPO
+mode=CSTE_MODE_LOCAL_REPO
+
+# mode specific init. (e.g. repository driver)
 if mode==CSTE_MODE_REMOTE_REPO_STUB:
         raise Exception()
@@ -72 +54 @@
 
 
+        # HACK
+        # (uncomment those two lines if use prodiguer repo)
+        import prodiguer_shared.repo.session as repo_session
+        import prodiguer_shared.models as models
+
+
+        # Test constants.
+        _SIM_ACTIVITY = 'IPSL'
+        _SIM_COMPUTE_NODE = 'TGCC'
+        _SIM_COMPUTE_NODE_LOGIN = 'p86denv'
+        _SIM_COMPUTE_NODE_MACHINE = 'TGCC - Curie'
+        _SIM_EXECUTION_START_DATE = datetime.datetime.now()
+        _SIM_EXECUTION_STATE = models.EXECUTION_STATE_RUNNING
+        _SIM_EXPERIMENT = '1pctCO2'
+        _SIM_MODEL_ENGINE = 'IPSL-CM5A-LR'
+        _SIM_SPACE = models.SIMULATION_SPACE_TEST
+        _MSG_TYPE = "0000"
+        _MSG_CONTENT1 = "12345690"
+        _MSG_CONTENT2 = "12345690"
+
 elif mode==CSTE_MODE_LOCAL_REPO:
+
         import local_repo as repo
+
+
 else:
         raise Exception("ERR001 - incorrect mode")
+