Skip to content

Commit 8926dff

Browse files
Temporarily disable table truncation
1 parent 1723097 commit 8926dff

File tree

1 file changed

+3
-1
lines changed
  • etl-destinations/src/deltalake

1 file changed

+3
-1
lines changed

etl-destinations/src/deltalake/core.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -449,12 +449,14 @@ where
449449
S: StateStore + SchemaStore + Send + Sync,
450450
{
451451
async fn truncate_table(&self, table_id: TableId) -> EtlResult<()> {
452+
// This is currently a no-op, due to the logic relying on table existence and schemas
453+
return Ok(());
452454
let table_path = self.get_table_path(table_id).await?;
453-
let table = self.ensure_table_exists(table_id).await?;
454455

455456
info!("Truncating Delta table for table_id: {}", table_id.0);
456457

457458
// Use delete with predicate "true" to remove all rows
459+
let table = self.ensure_table_exists(table_id).await?;
458460
let updated_table = self.client.truncate_table(table).await.map_err(|e| {
459461
etl_error!(
460462
ErrorKind::DestinationError,

0 commit comments

Comments
 (0)