diff --git a/src/worker/builder.rs b/src/worker/builder.rs index f5768216..6af64bfc 100644 --- a/src/worker/builder.rs +++ b/src/worker/builder.rs @@ -154,6 +154,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 } }