Commit 69f47ee0 authored by aknecht2's avatar aknecht2
Browse files

Updated config to a class variable.

parent fee211b8
......@@ -293,7 +293,7 @@ class Workflow(object):
notify = textwrap.dedent("""\
#!/bin/bash
%s/notification/email -t %s --report=pegasus-analyzer
""" % (config["notify"]["pegasus_home"], config["notify"]["email"]))
""" % (self.config["notify"]["pegasus_home"], self.config["notify"]["email"]))
wh.write(notify)
os.chmod(notify_path, 0755)
self.dax.invoke(When.AT_END, notify_path)
......@@ -337,9 +337,9 @@ class Workflow(object):
os.path.join(self.basepath, "work")
)
# NEED TO DETERMINE HOW TO READ IN THIS INFO
for namespace in config["profile"]:
for key in config["profile"][namespace]:
val = ":".join(config["profile"][namespace][key]) if "path" in key.lower() else config["profile"][namespace][key]
for namespace in self.config["profile"]:
for key in self.config["profile"][namespace]:
val = ":".join(self.config["profile"][namespace][key]) if "path" in key.lower() else self.config["profile"][namespace][key]
sites += """\n\t<profile namespace="%s" key="%s">%s</profile> """ % (namespace, key, val)
sites += "</site></sitecatalog>"
sites = sites.replace("\n", "")
......
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