def METHOD_NAME(new_status, job_id):
    job_id = job_id or 'unknown'
    try:
        message = "Publishing Pulsar state change with status {} for job_id {}".format(new_status, job_id)
        log.debug(message)
        payload = manager_endpoint_util.full_status(manager, new_status, job_id)
        pulsar_exchange.publish("status_update", payload)
    except Exception:
        log.exception("Failure to publish Pulsar state change for job_id %s." % job_id)
        raise