diff --git a/src/worker/builder.rs b/src/worker/builder.rs index 2a8d5eed..3c5d9aee 100644 --- a/src/worker/builder.rs +++ b/src/worker/builder.rs @@ -183,6 +183,7 @@ impl WorkerBuilder { ) -> Result, E>, Error> { let url = utils::parse_provided_or_from_env(url)?; let stream = TokioStream::connect(utils::host_from_url(&url)).await?; - self.connect_with(stream, None).await + self.connect_with(stream, url.password().map(|p| p.to_string())) + .await } }