This commit is contained in:
asafmahlev 2024-04-11 10:33:58 +03:00
Родитель e254d544ec
Коммит 808be007bc
3 изменённых файлов: 3 добавлений и 3 удалений

Просмотреть файл

@ -44,7 +44,7 @@ once_cell = "1"
arrow = { version = "50.0.0", features = ["prettyprint"] }
dotenv = "0.15.0"
env_logger = "0.10.0"
tokio = { version = "1.25.0", features = ["macros"] }
tokio = { version = "1.25.0", features = ["macros", "rt-multi-thread"] }
oauth2 = "4.3.0"
criterion = "0.5"
clap = { version = "4.1.6", features = ["derive", "env"] }

Просмотреть файл

@ -62,7 +62,7 @@ impl CloudInfo {
);
request.insert_headers(&Accept::from("application/json"));
request.insert_headers(&AcceptEncoding::from("gzip, deflate"));
let response = pipeline.send(&mut Context::new(), &mut request).await?;
let response = pipeline.send(&Context::new(), &mut request).await?;
let (status_code, _header_map, pinned_stream) = response.deconstruct();
match status_code {
StatusCode::Ok => {

Просмотреть файл

@ -80,7 +80,7 @@ impl QueryRunner {
let response = self
.client
.pipeline()
.send(&mut context, &mut request)
.send(&context, &mut request)
.await?;
Ok(response)
}