async def corofunc2():
            called[1] = True
            return event.ReturnValue(eat=True)
def rpc_send_message(orchestrator, audit_name, message):

    # Enqueue the ACK message.
    orchestrator.enqueue_msg(message)