Skip to content
Snippets Groups Projects

caching_refinements

Merged Jim Sheckard requested to merge caching_refinements into main
1 file
+ 2
2
Compare changes
  • Side-by-side
  • Inline
@@ -571,7 +571,7 @@ class WorkflowService(WorkflowServiceIF):
:param dir_path: path of the directory that will be submitted to condor
:return:
"""
extensions = ["*.condor", ".dag", ".log"]
extensions = ["*.condor", "*.dag", "*.log", "*.sh", "*.err.txt", "*.out.txt"]
old_files = itertools.chain.from_iterable(dir_path.glob(pattern) for pattern in extensions)
if len(list(old_files)) > 0:
@@ -846,7 +846,7 @@ class WorkflowMessageHandler:
self._process_message_for_request(message, request)
else:
logger.warning(
f"No workflow request found for request id #{request_id}," f" from message subject {msg_subject}."
f"No workflow request found for request id #{request_id}, from message subject {msg_subject}."
)
else:
logger.warning(f"Message {message} does not concern a workflow request. Ignoring.")
Loading