Skip to content

Commit a282d79

Browse files
authored
Add result-side monitoring update (#3837)
# Description This is a followup to #3833; had meant to add it in there after #3834, but miscommunicated so adding now. # Changed Behaviour Adds a result-side monitoring messages for managers that send results. No workflows should be impacted, but there is now an additional NODEINFO record in the sqlite database. This PR will bring the total up to 4 (as shown in the changed test). ## Type of change - New feature
1 parent ca6153f commit a282d79

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

parsl/executors/high_throughput/interchange.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -548,6 +548,8 @@ def process_results_incoming(self, interesting_managers: Set[bytes], monitoring_
548548
if len(m['tasks']) == 0 and m['idle_since'] is None:
549549
m['idle_since'] = time.time()
550550

551+
self._send_monitoring_info(monitoring_radio, m)
552+
551553
logger.debug("Current tasks on manager %r: %s", manager_id, m["tasks"])
552554

553555
logger.debug("leaving results_incoming section")

parsl/tests/test_monitoring/test_basic.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ def test_row_counts(tmpd_cwd, fresh_config):
120120
# Two entries: one showing manager active, one inactive
121121
result = connection.execute(text("SELECT COUNT(*) FROM node"))
122122
(c, ) = result.first()
123-
assert c == 3
123+
assert c == 4
124124

125125
# There should be one block polling status
126126
# local provider has a status_polling_interval of 5s

0 commit comments

Comments
 (0)