HTCondor log files path

lawluigi_configs/KingMaker_luigi.cfg

@@ -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
@@ -112,4 +112,4 @@ friend_mapping = {}
 silent = True
 ; set to False to print out the datasets
 
-[QuantitiesMap]
+[QuantitiesMap]

processor/tasks/CROWNBase.py

@@ -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):
     """
@@ -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__