cmd: add flux-post-job-event.py

Problem: There's no convenient way to post job events manually when
it's necessary.

Add a new `flux post-job-event` command which sends an RPC to the
job-manager.post-event.post service when called, e.g.:

  flux post-job-event JOBID NAME [KEY=VAL, KEY=VAL..]

This command is meant to be a temporary solution to clean up cases
where a job gets stuck in CLENAUP becuase an epilog-start event was
posted without a corresponding epilog-finish event.

Author: grondo

src/cmd/Makefile.am

@@ -120,7 +120,8 @@ dist_fluxcmd_SCRIPTS = \
 	flux-update.py \
 	flux-imp-exec-helper \
 	py-runner.py \
-	flux-hostlist.py
+	flux-hostlist.py \
+	flux-post-job-event.py
 
 fluxcmd_PROGRAMS = \
 	flux-terminus \

src/cmd/flux-post-job-event.py

@@ -0,0 +1,55 @@
+#!/bin/false
+##############################################################
+# Copyright 2024 Lawrence Livermore National Security, LLC
+# (c.f. AUTHORS, NOTICE.LLNS, COPYING)
+#
+# This file is part of the Flux resource manager framework.
+# For details, see https://github.com/flux-framework.
+#
+# SPDX-License-Identifier: LGPL-3.0
+##############################################################
+
+import argparse
+import logging
+
+import flux
+from flux.job import JobID
+from flux.util import TreedictAction
+
+
+def post_event(args):
+    """Post an event to the job-manager.post-event.post service"""
+
+    req = {"id": JobID(args.id), "name": args.name}
+    if args.context:
+        req["context"] = args.context
+
+    try:
+        flux.Flux().rpc("job-manager.post-event.post", req).get()
+    except FileNotFoundError:
+        raise ValueError(f"No such job {args.id}")
+
+
+LOGGER = logging.getLogger("flux-job-post-event")
+
+
+@flux.util.CLIMain(LOGGER)
+def main():
+    parser = argparse.ArgumentParser(prog="flux-job-post-event")
+    parser.add_argument("id", help="jobid to which event shall be posted")
+    parser.add_argument("name", help="name of event to post")
+    parser.add_argument(
+        "context",
+        help="List of key=value pairs to set as event context",
+        action=TreedictAction,
+        nargs=argparse.REMAINDER,
+    )
+    parser.set_defaults(func=post_event)
+    args = parser.parse_args()
+    args.func(args)
+
+
+if __name__ == "__main__":
+    main()
+
+# vi: ts=4 sw=4 expandtab