Skip to content

Commit

Permalink
Updating search example so that it does not use pycbc_submit_dax
Browse files Browse the repository at this point in the history
  • Loading branch information
alishahassan committed Nov 15, 2024
1 parent 53b1757 commit 32d74a2
Show file tree
Hide file tree
Showing 5 changed files with 18 additions and 8 deletions.
3 changes: 3 additions & 0 deletions bin/pycbc_submit_dax
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,9 @@ SUBMIT_DIR=`mktemp --tmpdir=${LOCAL_PEGASUS_DIR} -d pycbc-tmp.XXXXXXXXXX`

#Make sure the directory is world readable
chmod 755 $SUBMIT_DIR
echo "THE SUBMIT DIR IS: "
echo $SUBMIT_DIR
echo $LOCAL_PEGASUS_DIR

# find the site-local template directory
if [ $DATA_INLINE == "True" ] ; then
Expand Down
3 changes: 2 additions & 1 deletion examples/search/gen.sh
Original file line number Diff line number Diff line change
Expand Up @@ -5,4 +5,5 @@ pycbc_make_offline_search_workflow \
--workflow-name gw \
--output-dir output \
--config-files analysis.ini plotting.ini executables.ini injections_minimal.ini \
--config-overrides results_page:output-path:$(pwd)/html
--config-overrides results_page:output-path:$(pwd)/html \
--submit-now
7 changes: 3 additions & 4 deletions examples/search/master.sh
Original file line number Diff line number Diff line change
@@ -1,12 +1,11 @@
#!/bin/bash
set -e

bash -e get.sh
bash -e bank.sh
bash -e stats.sh
#bash -e get.sh
#bash -e bank.sh
#bash -e stats.sh
bash -e gen.sh

cp *.gwf output
cd output
bash -e ../submit.sh
python ../check_job.py
3 changes: 0 additions & 3 deletions examples/search/submit.sh

This file was deleted.

10 changes: 10 additions & 0 deletions pycbc/workflow/pegasus_workflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@
import tempfile
import subprocess
import warnings
import platform
from packaging import version
from urllib.request import pathname2url
from urllib.parse import urljoin, urlsplit
Expand Down Expand Up @@ -357,6 +358,15 @@ def __init__(self, name='my_workflow', directory=None, cache_file=None,
self.name = name
self._rc = dax.ReplicaCatalog()
self._tc = dax.TransformationCatalog()
#(Self Inserted Code)
if platform.system() == "Darwin":
tar = Transformation(
"tar",
site="local",
pfn="/usr/bin/tar",
is_stageable=False,
)
self._tc.add_transformations(tar)

if directory is None:
self.out_dir = os.getcwd()
Expand Down

0 comments on commit 32d74a2

Please sign in to comment.