fileinfo and posts
Showing
1 changed file
with
6 additions
and
6 deletions
... | @@ -238,7 +238,7 @@ async fn clean_files_batch( | ... | @@ -238,7 +238,7 @@ async fn clean_files_batch( |
238 | let rows = client | 238 | let rows = client |
239 | .query(query, &[&millisecond_epoch, &offset, &limit]) | 239 | .query(query, &[&millisecond_epoch, &offset, &limit]) |
240 | .await | 240 | .await |
241 | .context("Failed to fetch file info rows")?; | 241 | .context("Failed to fetch fileinfo rows")?; |
242 | 242 | ||
243 | let mut more_results = false; | 243 | let mut more_results = false; |
244 | 244 | ||
... | @@ -309,7 +309,7 @@ async fn delete_file_info_rows( | ... | @@ -309,7 +309,7 @@ async fn delete_file_info_rows( |
309 | trace!("Params: {:#?}", &millisecond_epoch); | 309 | trace!("Params: {:#?}", &millisecond_epoch); |
310 | if dry_run { | 310 | if dry_run { |
311 | info!( | 311 | info!( |
312 | "[DRY RUN] Would delete file info rows older than {}", | 312 | "[DRY RUN] Would delete `fileinfo` rows older than {}", |
313 | millisecond_epoch | 313 | millisecond_epoch |
314 | ); | 314 | ); |
315 | return Ok(()); | 315 | return Ok(()); |
... | @@ -317,8 +317,8 @@ async fn delete_file_info_rows( | ... | @@ -317,8 +317,8 @@ async fn delete_file_info_rows( |
317 | let result = client | 317 | let result = client |
318 | .execute(query, &[&millisecond_epoch]) | 318 | .execute(query, &[&millisecond_epoch]) |
319 | .await | 319 | .await |
320 | .context("Failed to delete file info rows")?; | 320 | .context("Failed to delete `fileinfo` rows")?; |
321 | info!("Removed {} file information rows", result); | 321 | info!("Removed {} fileinfo rows", result); |
322 | Ok(()) | 322 | Ok(()) |
323 | } | 323 | } |
324 | 324 | ||
... | @@ -331,7 +331,7 @@ async fn delete_post_rows(client: &Client, millisecond_epoch: i64, dry_run: bool | ... | @@ -331,7 +331,7 @@ async fn delete_post_rows(client: &Client, millisecond_epoch: i64, dry_run: bool |
331 | trace!("Params: {:#?}", &millisecond_epoch); | 331 | trace!("Params: {:#?}", &millisecond_epoch); |
332 | if dry_run { | 332 | if dry_run { |
333 | info!( | 333 | info!( |
334 | "[DRY RUN] Would delete post rows older than {}", | 334 | "[DRY RUN] Would delete `posts` rows older than {}", |
335 | millisecond_epoch | 335 | millisecond_epoch |
336 | ); | 336 | ); |
337 | return Ok(()); | 337 | return Ok(()); |
... | @@ -339,7 +339,7 @@ async fn delete_post_rows(client: &Client, millisecond_epoch: i64, dry_run: bool | ... | @@ -339,7 +339,7 @@ async fn delete_post_rows(client: &Client, millisecond_epoch: i64, dry_run: bool |
339 | let result = client | 339 | let result = client |
340 | .execute(query, &[&millisecond_epoch]) | 340 | .execute(query, &[&millisecond_epoch]) |
341 | .await | 341 | .await |
342 | .context("Failed to delete post rows")?; | 342 | .context("Failed to delete `posts` rows")?; |
343 | info!("Removed {} post rows", result); | 343 | info!("Removed {} post rows", result); |
344 | Ok(()) | 344 | Ok(()) |
345 | } | 345 | } | ... | ... |
-
Please register or sign in to post a comment