Skip to content

Commit 3907e63

Browse files
authored
Add task info to log line (#3776)
Otherwise only an almost-helpful log line. # Changed Behaviour No change of note; log line is level INFO, not WARNING, and include the task id. Most users will likely never heed this line. ## Type of change - Update to human readable text: Documentation/error messages/comments
1 parent 487a784 commit 3907e63

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

parsl/executors/high_throughput/mpi_resource_management.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,16 +163,17 @@ def put_task(self, task_package: dict):
163163
_f, _args, _kwargs, resource_spec = unpack_res_spec_apply_message(task_package["buffer"])
164164

165165
nodes_needed = resource_spec.get("num_nodes")
166+
tid = task_package["task_id"]
166167
if nodes_needed:
167168
try:
168169
allocated_nodes = self._get_nodes(nodes_needed)
169170
except MPINodesUnavailable:
170-
logger.warning("Not enough resources, placing task into backlog")
171+
logger.info(f"Not enough resources, placing task {tid} into backlog")
171172
self._backlog_queue.put((nodes_needed, task_package))
172173
return
173174
else:
174175
resource_spec["MPI_NODELIST"] = ",".join(allocated_nodes)
175-
self._map_tasks_to_nodes[task_package["task_id"]] = allocated_nodes
176+
self._map_tasks_to_nodes[tid] = allocated_nodes
176177
buffer = pack_res_spec_apply_message(_f, _args, _kwargs, resource_spec)
177178
task_package["buffer"] = buffer
178179
task_package["resource_spec"] = resource_spec

0 commit comments

Comments
 (0)