We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ceefc7a commit 4373189Copy full SHA for 4373189
udata_hydra/cli.py
@@ -371,13 +371,14 @@ async def purge_csv_tables(quiet: bool = False) -> None:
371
error_count = 0
372
373
conn_csv = await connection(db_name="csv")
374
+ log.debug(f"{len(tables_to_delete)} tables to delete")
375
for table in tables_to_delete:
376
try:
377
async with conn_main.transaction():
378
async with conn_csv.transaction():
379
log.debug(f'Deleting table "{table}"')
380
await conn_csv.execute(f'DROP TABLE IF EXISTS "{table}"')
- await conn_main.execute(
381
+ await conn_csv.execute(
382
"DELETE FROM tables_index WHERE parsing_table = $1", table
383
)
384
await conn_main.execute(
0 commit comments