Commit fee211b8 authored by aknecht2's avatar aknecht2
Browse files

Added config loading.

parent 266ffda9
......@@ -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 = {}
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment