-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Removed deprecated
_pegasus_properties
(#196)
* Update htcondor.py * Happy pre-commit --------- Co-authored-by: dachengx <[email protected]>
- Loading branch information
Showing
1 changed file
with
0 additions
and
30 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -21,7 +21,6 @@ | |
Operation, | ||
Namespace, | ||
Arch, | ||
Properties, | ||
SiteCatalog, | ||
Transformation, | ||
TransformationCatalog, | ||
|
@@ -235,35 +234,6 @@ def _setup_wf_id(self): | |
else: | ||
self.wf_id = datetime.now().strftime("%Y-%m-%d-%H-%M-%S") | ||
|
||
def _pegasus_properties(self): | ||
"""Writes the file pegasus.properties. | ||
This file contains configuration settings used by Pegasus and HTCondor. | ||
""" | ||
props = Properties() | ||
|
||
# Don't ask why, but this is necessary for the Pegasus API to work | ||
props["pegasus.metrics.app"] = "XENON" | ||
props["pegasus.data.configuration"] = "nonsharedfs" | ||
|
||
# Give jobs a total of 1+{retry} tries | ||
props["dagman.retry"] = self.dagman_retry | ||
# Make sure we do start too many jobs at the same time | ||
props["dagman.maxidle"] = self.dagman_maxidle | ||
# Total number of jobs cap | ||
props["dagman.maxjobs"] = self.dagman_maxjobs | ||
|
||
# Help Pegasus developers by sharing performance data | ||
props["pegasus.monitord.encoding"] = "json" | ||
props["pegasus.catalog.workflow.amqp.url"] = ( | ||
"amqp://friend:[email protected]:5672/prod/workflows" | ||
) | ||
|
||
# write properties file to ./pegasus.properties | ||
props.write() | ||
self.pegasus_properties = props | ||
|
||
def _make_pegasus_config(self): | ||
"""Make the Pegasus configuration into a dict to pass as keywords argument later.""" | ||
pconfig = {} | ||
|