Function handle_step_query 

pub async fn handle_step_query(
    payload: Value,
    pool: PgPool,
    nats_client: Client,
    reply: Option<String>,
) -> Result<()>

Handles incoming queries for step status or output data over NATS.