Skip to content

Commit

Permalink
Do not transfer htcondor output file, use same wlcg storage for softw…
Browse files Browse the repository at this point in the history
…are and data.
  • Loading branch information
yrath committed Sep 28, 2020
1 parent 4f5b258 commit b84c3c8
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 14 deletions.
16 changes: 9 additions & 7 deletions analysis/tasks/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -266,7 +266,7 @@ def sandbox_setup_cmds(self):
return cmds


class GridWorkflow(AnalysisTask, AnalysisSandboxTask, law.glite.GLiteWorkflow, law.arc.ARCWorkflow, HTCondorWorkflow):
class GridWorkflow(AnalysisTask, law.glite.GLiteWorkflow, law.arc.ARCWorkflow, HTCondorWorkflow):

glite_ce_map = {
"CNAF": [
Expand All @@ -293,6 +293,7 @@ class GridWorkflow(AnalysisTask, AnalysisSandboxTask, law.glite.GLiteWorkflow, l
grid_ce = law.CSVParameter(default=["RWTH"], significant=False, description="target computing "
"element(s)")

req_sandbox = "slc7" # sandbox key
sandbox = "singularity::/cvmfs/singularity.opensciencegrid.org/cmssw/cms:rhel7-m20200612"

exclude_params_branch = {"grid_ce"}
Expand Down Expand Up @@ -407,11 +408,12 @@ def htcondor_job_config(self, config, job_num, branches):
self._setup_render_variables(config, self.htcondor_workflow_requires())
config.render_variables["output_uri"] = self.htcondor_output_uri()
config.universe = "grid"
config.stdout = "out.txt"
config.stderr = "err.txt"
config.log = "log.txt"
#config.stdout = "out.txt"
#config.stderr = "err.txt"
#config.log = "log.txt"
config.custom_content.append(("grid_resource", "condor {}".format(self.htcondor_ce[0])))
config.custom_content.append(("use_x509userproxy", "true"))
config.custom_content.append(("transfer_output_files", '""'))

return config

Expand Down Expand Up @@ -491,7 +493,7 @@ def complete(self):

def single_output(self):
path = "{}.tgz".format(os.path.basename(self.get_cmssw_path()))
return self.wlcg_target(path, fs="wlcg_fs_software")
return self.wlcg_target(path)

def output(self):
return law.tasks.TransferLocalFile.output(self)
Expand All @@ -516,7 +518,7 @@ def store_parts(self):
return super(UploadSoftware, self).store_parts() + (sl_dist_version,)

def single_output(self):
return self.wlcg_target("software.tgz", fs="wlcg_fs_software")
return self.wlcg_target("software.tgz")

def run(self):
# create the local bundle
Expand Down Expand Up @@ -547,7 +549,7 @@ def get_repo_path(self):

def single_output(self):
path = "{}.{}.tgz".format(os.path.basename(self.get_repo_path()), self.checksum)
return self.wlcg_target(path, fs="wlcg_fs_software")
return self.wlcg_target(path)

def output(self):
return law.tasks.TransferLocalFile.output(self)
Expand Down
7 changes: 0 additions & 7 deletions law.cfg
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,6 @@ base: srm://grid-srm.physik.rwth-aachen.de:8443/srm/managerv2?SFN=/pnfs/physik.r
base_listdir: gsiftp://grid-srm.physik.rwth-aachen.de//pnfs/physik.rwth-aachen.de/cms/store/user/$JTSF_GRID_USER/jet-tagging-sf
cache_root: $JTSF_LOCAL_CACHE

[wlcg_fs_software]

base: srm://grid-srm.physik.rwth-aachen.de:8443/srm/managerv2?SFN=/pnfs/physik.rwth-aachen.de/cms/store/user/$JTSF_GRID_USER/jet-tagging-sf
base_listdir: gsiftp://grid-srm.physik.rwth-aachen.de//pnfs/physik.rwth-aachen.de/cms/store/user/$JTSF_GRID_USER/jet-tagging-sf
cache_root: $JTSF_LOCAL_CACHE


[notifications]

slack_token: $JTSF_SLACK_TOKEN
Expand Down

0 comments on commit b84c3c8

Please sign in to comment.