We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d4ad2b5 commit 8c0e9bdCopy full SHA for 8c0e9bd
ensemble/members/flux/queue.py
@@ -1,3 +1,4 @@
1
+import os
2
import shlex
3
import sys
4
import time
@@ -308,10 +309,9 @@ def setup_flux_heartbeat(self):
308
309
return
310
311
# Customize the heartbeat duration by reloading the module
- self.handle.rpc("module.remove", {"name": "heartbeat"}).get()
312
- self.handle.rpc(
313
- "module.load", {"path": "heartbeat", "args": [f"period={self.cfg.heartbeat}s"]}
314
- ).get()
+ # We call to system flux since python can error
+ assert os.system("flux module remove heartbeat") == 0
+ assert os.system(f"flux module load heartbeat period={self.cfg.heartbeat}s") == 0
315
316
def heartbeat_callback(handle, msg_handler, msg, arg):
317
print("💗 HEARTBEAT")
0 commit comments