async fn queue_node_jobs(&self, connection: &mut Connection<'_, Prover>) {
        let l1_batch_ids = self
            .move_node_aggregation_jobs_from_waiting_to_queued(connection)
            .await;
        let len = l1_batch_ids.len();
        for (batch_id, circuit_id, depth) in l1_batch_ids {
            tracing::info!(
                "Marked node job for l1_batch {} and circuit_id {} at depth {} as queued.",
                batch_id,
                circuit_id,
                depth
            );
        }
        SERVER_METRICS
            .node_fri_witness_generator_waiting_to_queued_jobs_transitions
            .inc_by(len as u64);
    }
Marks node witness jobs as queued.
The trigger condition is all prover jobs on round 1 (or 2 if recursing) for a given circuit, per batch, have been completed.
prover/crates/bin/prover_job_monitor/src/witness_job_queuer.rs