Skip to content

Commit 956baa0

Browse files
osipovartemeadgbear
authored andcommitted
Move DBT_SERIALIZATION_FORMAT to cli (#286)
* Move dbt_ser_fmt to cli * Rename the field
1 parent 6b6719b commit 956baa0

File tree

3 files changed

+3
-13
lines changed

3 files changed

+3
-13
lines changed

crates/runtime/src/execution/utils.rs

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -61,15 +61,6 @@ impl DataFormat {
6161
}
6262
}
6363

64-
impl std::fmt::Display for DataFormat {
65-
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
66-
match self {
67-
Self::Arrow => write!(f, "arrow"),
68-
Self::Json => write!(f, "json"),
69-
}
70-
}
71-
}
72-
7364
/*#[async_trait::async_trait]
7465
pub trait S3ClientValidation: Send + Sync {
7566
async fn get_aws_bucket_acl(

crates/runtime/src/http/dbt/handlers.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -173,15 +173,15 @@ pub async fn query(
173173
let json_resp = Json(JsonResponse {
174174
data: Option::from(ResponseData {
175175
row_type: columns.into_iter().map(Into::into).collect(),
176-
query_result_format: Some(serialization_format.to_string()),
177-
row_set: if serialization_format == SerializationFormat::Json {
176+
query_result_format: Some(data_format.to_string()),
177+
row_set: if data_format == DataFormat::Json {
178178
Option::from(ResponseData::rows_to_vec(
179179
records_to_json_string(&records)?.as_str(),
180180
)?)
181181
} else {
182182
None
183183
},
184-
row_set_base_64: if serialization_format == SerializationFormat::Arrow {
184+
row_set_base_64: if data_format == DataFormat::Arrow {
185185
Option::from(records_to_arrow_string(&records)?)
186186
} else {
187187
None

crates/runtime/src/http/mod.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@ use axum::{
2323
response::{IntoResponse, Response},
2424
Router,
2525
};
26-
2726
use http_body_util::BodyExt;
2827
use icebucket_metastore::Metastore;
2928
use std::sync::Arc;

0 commit comments

Comments
 (0)