(
config: &TemporalConfig,
)
| 231 | } |
| 232 | |
| 233 | async fn create_temporal_client( |
| 234 | config: &TemporalConfig, |
| 235 | ) -> Result<Option<TemporalClient>, Report<GraphError>> { |
| 236 | if let Some(host) = &config.address.temporal_host { |
| 237 | TemporalClientConfig::new( |
| 238 | Url::from_str(&format!("{host}:{}", config.address.temporal_port)) |
| 239 | .change_context(GraphError)?, |
| 240 | ) |
| 241 | .await |
| 242 | .change_context(GraphError) |
| 243 | .map(Some) |
| 244 | } else { |
| 245 | Ok(None) |
| 246 | } |
| 247 | } |
| 248 | |
| 249 | fn start_rest_server(router: axum::Router, address: HttpAddress, lifecycle: &ServerLifecycle) { |
| 250 | let shutdown = lifecycle.shutdown.clone(); |
no test coverage detected