async fn process_completed_execution(
        &mut self,
        source_id: source::Id,
        job_info: job::Info,
        _execution_details: execution::Details,
    ) {
        // Fetch the source and inform it that its child Job has completed.
        let source_handler = &mut self.sources.get_mut(&source_id).expect("should find source");
        source_handler.handle_job_completion(job_info);
        self.remove_source_if_necessary(&source_id);

        // Continue processing available jobs.
        self.process_next_job().await;
    }
// Propagates results of a completed job by cleaning up references, informing the parent source
// of the job completion, and checking if another job can be processed.
Propagates results of a completed job by cleaning up references, informing the parent source
of the job completion, and checking if another job can be processed.
Propagates results of a completed job by cleaning up references informing the parent source of the job completion and checking if another job can be processed .
async fn process_completed_execution(
        &mut self,
        source_id: source::Id,
        job_info: job::Info,
        _execution_details: execution::Details,
    ) {
        // Fetch the source and inform it that its child Job has completed.
        let source_handler = &mut self.sources.get_mut(&source_id).expect("should find source");
        source_handler.handle_job_completion(job_info);
        self.remove_source_if_necessary(&source_id);
        // Continue processing available jobs.
        self.process_next_job().await;
    }
async fn process_completed_execution ( & mut self , source_id : source :: Id , job_info : job :: Info , _execution_details : execution :: Details , ) { // Fetch the source and inform it that its child Job has completed. let source_handler = & mut self . sources . get_mut ( & source_id ) . expect ( " " ) ; source_handler . handle_job_completion ( job_info ) ; self . remove_source_if_necessary ( & source_id ) ; // Continue processing available jobs. self . process_next_job ( ) . await ; }
Propagates results of a completed job by cleaning up references, informing the parent source
of the job completion, and checking if another job can be processed.
Propagates results of a completed job by cleaning up references informing the parent source of the job completion and checking if another job can be processed .
&mut self
source_id
source::Id
job_info
job::Info
_execution_details
execution::Details
&mut self
source_id
source::Id
job_info
job::Info
_execution_details
execution::Details