Skip to content
Merged
Show file tree
Hide file tree
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions lawluigi_configs/KingMaker_luigi.cfg
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ log_level = WARNING
keep_alive = False
ping_interval = 20
wait_interval = 20
max_reschedules = 10
max_reschedules = 2

[DEFAULT]
name = KingMaker
Expand Down Expand Up @@ -76,15 +76,15 @@ shifts = None
[CROWNRun]
; HTCondor
htcondor_walltime = 10800
htcondor_request_memory = 16000
htcondor_request_memory = 10000
Comment thread
nshadskiy marked this conversation as resolved.
Outdated
htcondor_request_disk = 20000000
; for these eras, only one file per task is processed
problematic_eras = ["2018B", "2017C", "2016B-ver2"]

[CROWNFriends]
; HTCondor
htcondor_walltime = 10800
htcondor_request_memory = 16000
htcondor_request_memory = 10000
htcondor_request_disk = 20000000
; friends have to be run in single core mode to ensure a correct order of the tree entries
htcondor_request_cpus = 1
Expand Down
23 changes: 22 additions & 1 deletion processor/tasks/CROWNBase.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,9 @@
import hashlib
import time

# Determine KingMaker base directory dynamically from this file's location
KINGMAKER_BASE = os.path.normpath(os.path.join(os.path.dirname(__file__), "../.."))


class ProduceBase(Task, WrapperTask):
"""
Expand Down Expand Up @@ -154,7 +157,25 @@ class CROWNExecuteBase(HTCondorWorkflow, law.LocalWorkflow):
files_per_task = luigi.IntParameter()

def htcondor_output_directory(self):
return law.LocalDirectoryTarget(self.local_path(f"htcondor_files/{self.nick}"))
path = os.path.join(
KINGMAKER_BASE,
"data",
self.production_tag,
"htcondor_files",
"ntuples",
self.nick
)
class_name = self.__class__.__name__
if "Friend" in class_name:
path = os.path.join(
KINGMAKER_BASE,
"data",
self.production_tag,
"htcondor_files",
self.friend_name,
self.nick
)
return law.LocalDirectoryTarget(path)

def htcondor_job_config(self, config, job_num, branches):
class_name = self.__class__.__name__
Expand Down
2 changes: 1 addition & 1 deletion sample_database
Submodule sample_database updated 2747 files
Loading