File tree Expand file tree Collapse file tree
engine/packages/pegboard/src/ops/runner Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11use anyhow:: Result ;
22use epoxy_protocol:: generated:: v2:: CachingBehavior ;
3- use futures_util:: { StreamExt , TryStreamExt } ;
3+ use futures_util:: StreamExt ;
44use gas:: prelude:: * ;
55
66use crate :: keys;
@@ -74,12 +74,24 @@ async fn list_runner_config_enabled_dcs_inner(
7474 target_replicas : None ,
7575 save_empty : true ,
7676 } )
77- . await ? ;
77+ . await ;
7878
79- Ok ( res. value . map ( |_| dc. datacenter_label ) )
79+ match res {
80+ Ok ( res) => res. value . map ( |_| dc. datacenter_label ) ,
81+ Err ( err) => {
82+ tracing:: warn!(
83+ ?err,
84+ namespace_id=?input. namespace_id,
85+ runner_name=%input. runner_name,
86+ dc_label=dc. datacenter_label,
87+ "failed to read runner config from dc"
88+ ) ;
89+ None
90+ }
91+ }
8092 } )
8193 . buffer_unordered ( 512 )
82- . try_filter_map ( |x| std:: future:: ready ( Ok ( x ) ) )
83- . try_collect :: < Vec < _ > > ( )
94+ . filter_map ( std:: future:: ready)
95+ . collect :: < Vec < _ > > ( )
8496 . await
8597}
You can’t perform that action at this time.
0 commit comments