diff --git a/chipathlon/workflow.py b/chipathlon/workflow.py index ad8498050589ee5b4610b7f1ae590b3a6a4f4244..bc60d1f1248d374878c16763782184fb2bb6d273 100644 --- a/chipathlon/workflow.py +++ b/chipathlon/workflow.py @@ -17,7 +17,7 @@ from Pegasus.DAX3 import * class Workflow(object): - def __init__(self, jobhome, run_file, param_file, host, username, password): + def __init__(self, jobhome, run_file, param_file, config_file, host, username, password): # Initialize db connection self.mdb = chipathlon.db.MongoDB(host, username, password) # Jobname info & err @@ -27,6 +27,9 @@ class Workflow(object): # Input file info self.run_file = run_file self.param_file = param_file + self.config_file = config_file + with open(self.config_file, "r") as rh: + self.config = yaml.load(rh) # Dax specific info self.dax = ADAG(self.jobname) self.executables = {}