Fix debug logging

galaxyproject · Nov 15, 2018 · f46ab5a · f46ab5a
1 parent b8c97f1
commit f46ab5a
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/lib/galaxy/jobs/mapper.py b/lib/galaxy/jobs/mapper.py
@@ -210,12 +210,13 @@ def __determine_job_destination(self, params, raw_job_destination=None):
             raw_job_destination = self.job_wrapper.tool.get_job_destination(params)
         if raw_job_destination.runner == DYNAMIC_RUNNER_NAME:
             job_destination = self.__handle_dynamic_job_destination(raw_job_destination)
+            log.debug("(%s) Mapped job to destination id: %s", self.job_wrapper.job_id, job_destination.id)
             # Recursively handle chained dynamic destinations
-            job_destination = self.__determine_job_destination(
-                params, raw_job_destination=job_destination)
+            if job_destination.runner == DYNAMIC_RUNNER_NAME:
+                return self.__determine_job_destination(params, raw_job_destination=job_destination)
         else:
             job_destination = raw_job_destination
-        log.debug("(%s) Mapped job to destination id: %s", self.job_wrapper.job_id, job_destination.id)
+            log.debug("(%s) Mapped job to destination id: %s", self.job_wrapper.job_id, job_destination.id)
         return job_destination
 
     def __cache_job_destination(self, params, raw_job_destination=None):