File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -589,22 +589,22 @@ where
589589 let total_execution_duration = execution_metadata
590590 . worker_completed_timestamp
591591 . duration_since ( execution_metadata. worker_start_timestamp )
592- . unwrap ( ) ;
592+ . unwrap_or ( Duration :: ZERO ) ;
593593
594594 let queue_duration = execution_metadata
595595 . worker_start_timestamp // which is the start of execution
596596 . duration_since ( execution_metadata. queued_timestamp )
597- . unwrap ( ) ;
597+ . unwrap_or ( Duration :: ZERO ) ;
598598
599599 let fetch_duration = execution_metadata
600600 . input_fetch_completed_timestamp
601601 . duration_since ( execution_metadata. input_fetch_start_timestamp )
602- . unwrap ( ) ;
602+ . unwrap_or ( Duration :: ZERO ) ;
603603
604604 let execution_duration = execution_metadata
605605 . execution_completed_timestamp
606606 . duration_since ( execution_metadata. execution_start_timestamp )
607- . unwrap ( ) ;
607+ . unwrap_or ( Duration :: ZERO ) ;
608608
609609 EXECUTION_METRICS . execution_stage_duration . record (
610610 fetch_duration. as_secs_f64 ( ) ,
You can’t perform that action at this time.
0 commit comments