diff --git a/src/common/libjsc/jstatctl.c b/src/common/libjsc/jstatctl.c index e531b07b644a..f964a01db077 100644 --- a/src/common/libjsc/jstatctl.c +++ b/src/common/libjsc/jstatctl.c @@ -665,7 +665,7 @@ static int send_state_event (flux_t *h, job_state_t st, int64_t j) jsc_job_num2state (st)); goto done; } - if ((msg = flux_event_pack (topic, "{ s:I }", "lwj", j)) == NULL) { + if ((msg = flux_event_pack (topic, "{ s:I }", "jobid", j)) == NULL) { flux_log_error (h, "flux_event_pack"); goto done; } @@ -1137,7 +1137,7 @@ static void job_state_cb (flux_t *h, flux_msg_handler_t *mh, if (flux_msg_get_topic (msg, &topic) < 0) goto done; - if (flux_event_unpack (msg, NULL, "{ s:I }", "lwj", &jobid) < 0) { + if (flux_event_unpack (msg, NULL, "{ s:I }", "jobid", &jobid) < 0) { flux_log (h, LOG_ERR, "%s: bad message", __FUNCTION__); goto done; } diff --git a/src/modules/wreck/job.c b/src/modules/wreck/job.c index 7cd5f90ead2f..ac231f6a3dd6 100644 --- a/src/modules/wreck/job.c +++ b/src/modules/wreck/job.c @@ -192,7 +192,7 @@ static void send_create_event (flux_t *h, int64_t id, walltime = val; msg = flux_event_pack (topic, "{s:I,s:s,s:i,s:i,s:i,s:i}", - "lwj", id, "kvs_path", path, + "jobid", id, "kvs_path", path, "ntasks", ntasks, "ncores", ncores, "nnodes", nnodes, diff --git a/src/modules/wreck/wrexecd.c b/src/modules/wreck/wrexecd.c index e2b96e638514..2ca846c65b62 100644 --- a/src/modules/wreck/wrexecd.c +++ b/src/modules/wreck/wrexecd.c @@ -1127,7 +1127,7 @@ void send_job_state_event (struct prog_ctx *ctx, const char *state) } if ((msg = flux_event_pack (topic, "{ s:I, s:s }", - "lwj", ctx->id, + "jobid", ctx->id, "kvs_path", ctx->kvspath)) == NULL) { wlog_err (ctx, "flux_event_pack: %s", flux_strerror (errno)); goto out;